daniel.rodrigues/G-Scripts
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

att

Browse Source
This commit is contained in:
daniel.rodrigues 2026-01-16 09:08:13 -03:00
parent db158b929b
commit 0620fa776d
1 changed files with 80 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

81
Pedidos_mar.py
View File

@ -52,6 +52,8 @@ DB_CONNECTION_STRING = (
REQUEST_DELAY = 0.5 # Delay em segundos entre requisições para evitar rate limiting
TOKEN_REFRESH_INTERVAL = 50 # Renovar token a cada N lojas processadas
FAILED_STORES_MAX_RETRIES = 3 # Número máximo de tentativas para lojas que falharam
FAILED_STORES_RETRY_DELAY = 180 # Tempo de espera (em segundos) antes de tentar novamente lojas que falharam
# ===============================
# FUNÇÕES AUXILIARES
@ -455,23 +457,26 @@ BASE_HEADERS = {
# 4) LOOP POR LOJA
# ===============================
all_data = []
stores_processed = 0
failed_stores = []
def process_stores(stores_to_process, all_data, base_headers, token):
"""
Processa uma lista de lojas e retorna os dados coletados e as lojas que falharam.
"""
failed = []
processed_count = 0
for store in STORES:
print(f"\nProcessando loja {store}... ({stores_processed + 1}/{len(STORES)})")
for store in stores_to_process:
print(f"\nProcessando loja {store}... ({processed_count + 1}/{len(stores_to_process)})")
# Renovar token periodicamente a cada N lojas
if stores_processed > 0 and stores_processed % TOKEN_REFRESH_INTERVAL == 0:
print(f"\n[TOKEN] Renovação preventiva após {stores_processed} lojas...")
if processed_count > 0 and processed_count % TOKEN_REFRESH_INTERVAL == 0:
print(f"\n[TOKEN] Renovação preventiva após {processed_count} lojas...")
new_token = get_new_token()
if new_token:
TOKEN = new_token
BASE_HEADERS["authorization"] = TOKEN
BASE_HEADERS["x-authorization"] = TOKEN
token = new_token
base_headers["authorization"] = token
base_headers["x-authorization"] = token
headers = BASE_HEADERS.copy()
headers = base_headers.copy()
headers["storecode"] = store
# Processar loja com retry e callback para renovar token
@ -485,24 +490,60 @@ for store in STORES:
# Se precisou renovar token, atualiza os headers base
if needs_refresh:
new_token = get_new_token()
if new_token:
token = new_token
base_headers["authorization"] = token
base_headers["x-authorization"] = token
# Adicionar dados da loja ao total
all_data.extend(store_data)
processed_count += 1
if len(store_data) == 0:
failed.append(store)
print(f"Loja {store} processada: {len(store_data)} registros")
return failed, token
all_data = []
failed_stores = []
# Primeira passagem: processar todas as lojas
failed_stores, TOKEN = process_stores(STORES, all_data, BASE_HEADERS, TOKEN)
# Retry das lojas que falharam
retry_round = 0
while failed_stores and retry_round < FAILED_STORES_MAX_RETRIES:
retry_round += 1
print(f"\n{'=' * 60}")
print(f"[RETRY {retry_round}/{FAILED_STORES_MAX_RETRIES}] {len(failed_stores)} lojas falharam: {', '.join(failed_stores[:20])}{'...' if len(failed_stores) > 20 else ''}")
print(f"Aguardando {FAILED_STORES_RETRY_DELAY} segundos antes de tentar novamente...")
print(f"{'=' * 60}")
time.sleep(FAILED_STORES_RETRY_DELAY)
# Renovar token antes de tentar novamente
print(f"\n[TOKEN] Renovando token antes do retry...")
new_token = get_new_token()
if new_token:
TOKEN = new_token
BASE_HEADERS["authorization"] = TOKEN
BASE_HEADERS["x-authorization"] = TOKEN
# Adicionar dados da loja ao total
all_data.extend(store_data)
stores_processed += 1
# Tentar processar as lojas que falharam
stores_to_retry = failed_stores.copy()
failed_stores, TOKEN = process_stores(stores_to_retry, all_data, BASE_HEADERS, TOKEN)
if len(store_data) == 0:
failed_stores.append(store)
if not failed_stores:
print(f"\n[SUCESSO] Todas as lojas foram processadas com sucesso no retry {retry_round}!")
print(f"Loja {store} processada: {len(store_data)} registros")
# Resumo das lojas que falharam
# Resumo final das lojas que ainda falharam
if failed_stores:
print(f"\n[AVISO] {len(failed_stores)} lojas falharam: {', '.join(failed_stores[:20])}{'...' if len(failed_stores) > 20 else ''}")
print(f"\n{'=' * 60}")
print(f"[AVISO FINAL] {len(failed_stores)} lojas falharam após {FAILED_STORES_MAX_RETRIES} tentativas de retry:")
print(f" {', '.join(failed_stores)}")
print(f"{'=' * 60}")
# ===============================
# 5) SALVAR NO BANCO DE DADOS