#!/usr/bin/env python3 import json import os import traceback import sys import time def application(environ, start_response): # --- ROTA DE INTERFACE (GET) --- if environ.get('REQUEST_METHOD') == 'GET': start_response('200 OK', [('Content-Type', 'text/html; charset=utf-8')]) return [f""" LinkTudo - Diagnostic Lab Pro

âš¡ PARQUET DIAGNOSTIC LAB V5

CAMADA_01 // FILE_SYSTEM
1. VERIFICAÇÃO DE DISCO E PERMISSÕES

        


        

            
CAMADA_02 // PYARROW_METADATA

            
2. LEITURA DE CABEÇALHO (COLUNAS)

            
            
            

        


        

            
CAMADA_03 // FILTER_SCANNER

            
3. CONTAGEM MUNICIPIO 4733 (PESADO)

            
            
            

        


        
        
    


    


""".encode('utf-8')]

    # --- ROTA DE PROCESSAMENTO (POST) ---
    if environ.get('REQUEST_METHOD') == 'POST':
        start_response('200 OK', [('Content-Type', 'application/json; charset=utf-8')])
        try:
            length = int(environ.get('CONTENT_LENGTH', 0))
            body = json.loads(environ['wsgi.input'].read(length).decode('utf-8'))
            action = body.get('action')
            path = "/home/link6350/arquivos_restritos/banco_de_dados/parquet/cnpj/tabelas_auxiliares_pesadas/cnpj___tb_aux___estabelecimentos___por_cnae_por_logradouro___mais_agregacoes___para_filtro_personalizado___cliente_final.parquet"

            if action == 'teste_arquivo':
                s = os.stat(path)
                return [json.dumps({"existe": True, "tamanho_gb": round(s.st_size/(1024**3), 2), "permissoes": oct(s.st_mode)}).encode('utf-8')]

            if action == 'teste_metadados':
                import pyarrow.parquet as pq
                meta = pq.read_metadata(path)
                return [json.dumps({"total_linhas": meta.num_rows, "colunas": meta.schema.names}).encode('utf-8')]

            if action == 'teste_filtro':
                import pyarrow.parquet as pq
                # Forçamos a leitura de apenas 1 coluna para tentar passar no limite de RAM
                tabela = pq.read_table(path, columns=['municipio_codigo'], filters=[('municipio_codigo', '==', '4733')])
                return [json.dumps({"total_encontrado_4733": tabela.num_rows}).encode('utf-8')]

        except Exception as e:
            return [json.dumps({"status": "error", "message": str(e), "traceback": traceback.format_exc()}).encode('utf-8')]

    return [b"Metodo nao permitido"]