| 123456789101112131415161718192021222324 |
- ; Hive ads.ads_trd_group_funnel_daily → PG ads.ads_trd_group_funnel_daily
- ; 全量覆盖（数据小，每次 TRUNCATE 重灌全部历史分区）；funnel_dt(ORC) → dt(PG)
- ; 跑法：python3 bin/datax-hdfs-export-starter.py -ini jobs/ads/trd/ads_trd_group_funnel_daily.ini -start-date 20260621 -stop-date 20260621 -skip-check
- [reader]
- dataSource = hdfs/prd-hdfs-ha
- path = /user/hive/warehouse/ads.db/ads_trd_group_funnel_daily/dt=*/
- column = funnel_dt,uv_start,uv_show,uv_detail,uv_order,uv_paid,etl_time
- columnType =
- fileType = orc
- encoding = UTF-8
- compress =
- nullFormat =
- fieldDelimiter = \t
- [writer]
- dataSource = postgresql/dev-poyee-xiaoxu
- database = hs_sync_data
- table = ads.ads_trd_group_funnel_daily
- column = dt,uv_start,uv_show,uv_detail,uv_order,uv_paid,etl_time
- columnType =
- preSql = TRUNCATE TABLE ads.ads_trd_group_funnel_daily
- postSql =
- batchSize = 1024
|
