chore: 添加开发辅助脚本用于测试和数据库检查

新增 run_test_backfill.py 用于测试巴西贸易数据连接器的回填任务，新增 check_db.py 用于检查并展示数据库贸易记录。本次提交还包含临时日志文件与Python缓存文件，此类文件通常不应纳入版本控制。

check_db.py

@@ -0,0 +1,29 @@
+import asyncio
+from packages.core.database import AsyncSessionLocal
+from sqlalchemy import text
+
+async def main():
+    async with AsyncSessionLocal() as session:
+        # 1. 检查入库总数
+        r = await session.execute(text("select count(1) from standard_trade_records"))
+        print(f"总记录数: {r.scalar()}")
+        
+        # 2. 检查几条真实数据的翻译情况
+        query = """
+        select hs_code, product_name, origin_country, destination_country, 
+               departure_port, arrival_port, transport_mode, amount, weight 
+        from standard_trade_records 
+        limit 5
+        """
+        r = await session.execute(text(query))
+        print("\n数据样例:")
+        for row in r:
+            print(f"- HS: {row.hs_code}")
+            print(f"  商品名: {row.product_name}")
+            print(f"  原产国/目的国: {row.origin_country} -> {row.destination_country}")
+            print(f"  起运港/目的港: {row.departure_port} -> {row.arrival_port}")
+            print(f"  运输方式: {row.transport_mode}")
+            print(f"  金额/重量: ${row.amount} / {row.weight}KG")
+            print("---")
+
+asyncio.run(main())

logs/app_2026-06-10.log

@@ -45,3 +45,14 @@
 2026-06-10 22:57:13.171 | WARNING  | packages.core.http_client:request:79 - Request Error: [SSL: CERTIFICATE_VERIFY_FAILED] certificate verify failed: unable to get local issuer certificate (_ssl.c:1081) for https://balanca.economia.gov.br/balanca/bd/tabelas/VIA.csv
 2026-06-10 22:57:13.172 | WARNING  | packages.core.http_client:request:82 - SSL 证书校验失败，降级为 verify=False 重试: https://balanca.economia.gov.br/balanca/bd/tabelas/VIA.csv
 2026-06-10 22:57:13.174 | DEBUG    | packages.core.http_client:request:55 - Request: GET https://balanca.economia.gov.br/balanca/bd/tabelas/VIA.csv | Attempt: 2/3
+2026-06-10 23:00:09.588 | INFO     | __main__:run_backfill:16 - --- Starting BACKFILL Job for BR from 2026-05-01 to 2026-05-31 ---
+2026-06-10 23:00:11.742 | INFO     | packages.connectors.base:run:128 - [BR] Starting job, batch_no: BACKFILL_BR_202605_202605
+2026-06-10 23:00:12.412 | DEBUG    | packages.core.http_client:request:55 - Request: GET https://balanca.economia.gov.br/balanca/bd/comexstat-bd/ncm/EXP_2026.csv | Attempt: 1/3
+2026-06-10 23:00:14.140 | WARNING  | packages.core.http_client:request:79 - Request Error: [SSL: CERTIFICATE_VERIFY_FAILED] certificate verify failed: unable to get local issuer certificate (_ssl.c:1081) for https://balanca.economia.gov.br/balanca/bd/comexstat-bd/ncm/EXP_2026.csv
+2026-06-10 23:00:14.142 | WARNING  | packages.core.http_client:request:82 - SSL 证书校验失败，降级为 verify=False 重试: https://balanca.economia.gov.br/balanca/bd/comexstat-bd/ncm/EXP_2026.csv
+2026-06-10 23:00:14.164 | DEBUG    | packages.core.http_client:request:55 - Request: GET https://balanca.economia.gov.br/balanca/bd/comexstat-bd/ncm/EXP_2026.csv | Attempt: 2/3
+2026-06-10 23:26:13.157 | INFO     | packages.connectors.base:run:128 - [BR] Starting job, batch_no: TEST_BATCH_001
+2026-06-10 23:26:13.430 | DEBUG    | packages.core.http_client:request:55 - Request: GET https://balanca.economia.gov.br/balanca/bd/comexstat-bd/ncm/EXP_2026.csv | Attempt: 1/3
+2026-06-10 23:26:15.300 | WARNING  | packages.core.http_client:request:79 - Request Error: [SSL: CERTIFICATE_VERIFY_FAILED] certificate verify failed: unable to get local issuer certificate (_ssl.c:1081) for https://balanca.economia.gov.br/balanca/bd/comexstat-bd/ncm/EXP_2026.csv
+2026-06-10 23:26:15.300 | WARNING  | packages.core.http_client:request:82 - SSL 证书校验失败，降级为 verify=False 重试: https://balanca.economia.gov.br/balanca/bd/comexstat-bd/ncm/EXP_2026.csv
+2026-06-10 23:26:15.302 | DEBUG    | packages.core.http_client:request:55 - Request: GET https://balanca.economia.gov.br/balanca/bd/comexstat-bd/ncm/EXP_2026.csv | Attempt: 2/3

run_test_backfill.py

@@ -0,0 +1,18 @@
+import asyncio
+from packages.connectors.brazil import BrazilComexStatConnector
+from packages.core.database import AsyncSessionLocal
+
+async def main():
+    print("开始测试抓取...")
+    async with AsyncSessionLocal() as session:
+        connector = BrazilComexStatConnector(
+            session=session,
+            start_period="2026-05",
+            end_period="2026-05",
+            max_rows_per_slice=10  # 只抓 10 条
+        )
+        connector.batch_no = "TEST_BATCH_001"
+        await connector.run()
+    print("测试抓取结束.")
+
+asyncio.run(main())