songzhenxing_qm_DataSynchronismFormal
attribute_log_reader_fast
attribute_log_smallproject
日志接收系统
ods_fast_sdk_log
归因系统
下游各业务线
attribute_log_reader_free
bigdata_ad_v2_reader_fast
bigdata_matrix_small
Flume 导入离线链路
songzhenxing_fast_emrKafkaParser
kafka集群：bigdata-kafka
dwd_qm_agg_log
bigdata_matrix_xm
dwd_small_aggs_log
kafka_2_kafka_bigdata_matrix_qm
dwd_qm_aggs_log
kafka集群：链路重构
flink任务
rt_dwd_fast_aggs_log
bigdata_ad_v2_reader_free
songzhenxing_small_emrKafkaParser
dwd_fast_aggs_log
kafka_2_kafka_bigdata_matrix_xm
rt_dwd_small_aggs_log
图例说明： 1）上面实线箭头是实时链路2）中间蓝色箭头是开发中的流批一体链路3）下面虚线 是离线链路
ods_small_sdk_log
bigdata_matrix_qm
flink任务同步是emr
songzhenxing_fast_DataSynchronismFormal
离线hive链路
实时链路
新流批一体链路
kafka_2_kafka_bigdata_matrix_samll
bigdata_ad_v2_smallproject
flink任务，实时ods-> dwd
songzhenxing_small_DataSynchronismFormal
ods_qm_sdk_log
rt_dwd_qm_aggs_log
