Como coletar toda as notas tomadas diariamente?

[marcelodelta]

Estou com problema em: Erro 656: Rejeicao: Consumo Indevido (Deve ser aguardado 1 hora para efetuar nova solicitacao caso nao existam mais documentos a serem pesquisados. Tente apos 1 hora).

Fiz alguns ajustes, porém ainda sem sucesso.
Alguém poderia ajudar como poderia fazer isso ?

import time
from lxml import etree
from pynfe.processamento.comunicacao import ComunicacaoSefaz
from pynfe.utils.descompactar import DescompactaGzip
from pynfe.utils.flags import NAMESPACE_NFE
import datetime

certificado = ""
senha = ''
uf = 'sp'
homologacao = True
CPFCNPJ = ''
data_desejada = datetime.date(2023, 12, 21)
max_consultas_por_execucao = 10

con = ComunicacaoSefaz(uf, certificado, senha, homologacao)
NSU = 0
contador_consultas = 0

while contador_consultas < max_consultas_por_execucao:
    xml = con.consulta_distribuicao(cnpj=CPFCNPJ, chave='', nsu=NSU)
    resposta = etree.fromstring(xml.text.encode('utf-8'))
    ns = {'ns': NAMESPACE_NFE}
    
    cStat = resposta.xpath('//ns:retDistDFeInt/ns:cStat', namespaces=ns)[0].text
    xMotivo = resposta.xpath('//ns:retDistDFeInt/ns:xMotivo', namespaces=ns)[0].text

    if cStat != '138':
        print(f'Erro {cStat}: {xMotivo}')
        if cStat in ['137', '656']:
            break

    contador_resposta = len(resposta.xpath('//ns:retDistDFeInt/ns:loteDistDFeInt/ns:docZip', namespaces=ns))
    
    for contador_xml in range(contador_resposta):
        tipo_schema = resposta.xpath('//ns:retDistDFeInt/ns:loteDistDFeInt/ns:docZip/@schema', namespaces=ns)[contador_xml]
        
        if tipo_schema == 'procNFe_v4.00.xsd': 
            zip_resposta = resposta.xpath('//ns:retDistDFeInt/ns:loteDistDFeInt/ns:docZip', namespaces=ns)[contador_xml].text
            resposta_descompactado = DescompactaGzip.descompacta(zip_resposta)
            texto_descompactado = etree.tostring(resposta_descompactado).decode('utf-8')

            data_emissao_str = resposta_descompactado.xpath('//ns:NFe/ns:infNFe/ns:ide/ns:dhEmi', namespaces=ns)[0].text[:10]
            data_emissao = datetime.datetime.strptime(data_emissao_str, '%Y-%m-%d').date()

            if data_emissao == data_desejada:
                nome_arquivo = f'nfe-{NSU}-{contador_xml}.xml'
                with open(f'./{nome_arquivo}', 'w+', encoding='UTF-8') as f:
                    f.write(texto_descompactado)
                print(f'Arquivo salvo: {nome_arquivo}')

    NSU = int(resposta.xpath('//ns:retDistDFeInt/ns:ultNSU', namespaces=ns)[0].text)
    contador_consultas += 1
    if contador_consultas < max_consultas_por_execucao:
        time.sleep(60)

[aron0306]

@marcelodelta além do limite de 20 consultas/hora há também um limite em que se você consulta e o NSU retornado é igual ao valor do campo ultNSU (último NSU registrado) então você deve esperar 1h para fazer uma nova consulta.
Essa restrição é explicada no 1.1 desse informe (https://www.nfe.fazenda.gov.br/portal/informe.aspx?ehCTG=false&Informe=0cu/yBLKrCs=) de acordo com o erro que recebe.
Basicamente você pode fazer 20 consultas por hora mas se não houver novas notas em 1 das consultas você deve parar de consulta por 1h.