Como consultar as certidões de um fornecedor por API?

pip install fiscalapi-br
export FISCALAPI_API_KEY="fapi_sua_chave_aqui"

"""CND Federal, CNDT e CRF do FGTS de uma lista de CNPJs, com os PDFs."""
import base64
import csv
import os
import sys
import time

from fiscalapi_br import (
    APIConnectionError,
    AuthenticationError,
    BadRequestError,
    FiscalAPI,
    InsufficientBalanceError,
    RateLimitError,
    ServerError,
)

ENTRADA = "fornecedores.csv"   # coluna "cnpj"
SAIDA = "certidoes.csv"        # uma linha por certidão; é também o checkpoint
PASTA_PDF = "pdfs"
COLUNAS = ["cnpj", "certidao", "status", "validade_iso", "numero", "pdf", "erro"]

# Segundos entre chamadas, pelo limite por minuto do plano.
PAUSA = {"lite": 12.0, "starter": 3.0, "pro": 1.0, "enterprise": 0.5}
PLANO = "starter"


def limpar(valor: str) -> str:
    return "".join(c for c in valor if c.isalnum()).upper()


def ja_feitas() -> set[tuple[str, str]]:
    if not os.path.exists(SAIDA):
        return set()
    with open(SAIDA, encoding="utf-8", newline="") as f:
        return {(linha["cnpj"], linha["certidao"]) for linha in csv.DictReader(f)}


def gravar(linha: dict) -> None:
    novo = not os.path.exists(SAIDA)
    with open(SAIDA, "a", encoding="utf-8", newline="") as f:
        w = csv.DictWriter(f, fieldnames=COLUNAS)
        if novo:
            w.writeheader()
        w.writerow(linha)


def consultar(chamada, cnpj: str) -> dict:
    """Chama a rota e espera se a certidão ainda estiver sendo emitida."""
    for _ in range(4):
        resp = chamada(cnpj=cnpj)
        if resp["source_status"].get("error_code") != "EM_PROCESSAMENTO":
            return resp
        # O tempo sugerido vem no header Retry-After, que o SDK não expõe: 30 s cobre.
        time.sleep(30)
    return resp


def main() -> None:
    api = FiscalAPI()  # lê FISCALAPI_API_KEY; repete sozinho em 429 e 5xx
    certidoes = {
        "cnd_federal": api.consultar_cnd_federal,
        "cndt": api.consultar_cndt,
        "crf_fgts": api.consultar_crf_fgts,
    }
    os.makedirs(PASTA_PDF, exist_ok=True)
    with open(ENTRADA, encoding="utf-8-sig", newline="") as f:   # utf-8-sig: aceita CSV salvo pelo Excel
        cnpjs = list(dict.fromkeys(limpar(linha["cnpj"]) for linha in csv.DictReader(f)))
    feitas = ja_feitas()

    for cnpj in filter(None, cnpjs):
        for nome, chamada in certidoes.items():
            if (cnpj, nome) in feitas:
                continue
            inicio = time.monotonic()
            linha = {"cnpj": cnpj, "certidao": nome}
            try:
                resp = consultar(chamada, cnpj)
            except InsufficientBalanceError as e:
                print(f"Parei no {cnpj}: {e.message}. Rode de novo depois de recarregar.")
                sys.exit(2)
            except AuthenticationError as e:
                print(f"Chave recusada: {e.message}")
                sys.exit(3)
            except BadRequestError as e:
                gravar({**linha, "erro": e.code})          # pedido recusado: não repete
                continue
            except RateLimitError as e:
                time.sleep(e.retry_after or 60)             # fica para a próxima rodada
                continue
            except (ServerError, APIConnectionError):
                continue                                    # fica para a próxima rodada

            codigo = resp["source_status"].get("error_code") or ""
            r = resp.get("result")
            if codigo in ("CNPJ_INVALIDO", "CPF_INVALIDO"):
                # Vem em HTTP 200, sem exceção. Não é cobrado e não adianta repetir.
                gravar({**linha, "erro": codigo})
            elif not r or r["status"] == "erro":
                # O órgão não respondeu ou recusou o pedido. Não é cobrado e não é gravado:
                # entra de novo na próxima rodada. A mensagem diz o motivo.
                print(cnpj, nome, codigo or (r or {}).get("status_raw", ""))
            else:
                if r.get("pdf_base64"):
                    linha["pdf"] = os.path.join(PASTA_PDF, f"{cnpj}_{nome}.pdf")
                    with open(linha["pdf"], "wb") as f:
                        f.write(base64.b64decode(r["pdf_base64"]))
                gravar({**linha, "status": r["status"], "validade_iso": r.get("validade_iso", ""),
                        "numero": r.get("protocolo", "")})

            espera = PAUSA[PLANO] - (time.monotonic() - inicio)
            if espera > 0:
                time.sleep(espera)

    print("Fim. O que não entrou em certidoes.csv é consultado se você rodar de novo.")


if __name__ == "__main__":
    main()

resp = api.consultar_certidoes_todas(cnpj="12345678000195", skip_estaduais=True)
for c in resp["certidoes_federais"]:
    if c["result"]:
        print(c["result"]["tipo"], c["result"]["status"], c["result"]["validade_iso"])