1、123451 + + +21. 2. 1. 2.1. 2. data sourceprocessing & storageservicesopen falconmonitoringairflowscheduleelasticsearch?tracking?PVTOdatawarehouseflumehdfshbasehiveloadbatchsparkwebapiopen apicrawlerhivehbasereal-timespark streamingconsumekafka?9AIpersonalityschedulingPHWDGDWDredisuserIdIDCookieIDjoi
2、npipeline31?軀?樁?80?06TO?軀?軀?軀?1?8?(7&?0?Presto?8?SQLDSS?1? ?8? ? ?KafkaETCD/trigger/task3task312:00Node1Node2Node3task1, task2, task3task1, task2task1, task2, task3task1, task2task1, task2, task3task1, task2ETCDnow 12:00/ready/task3Node1Node2Node3task1, task2, task3task1, task2, task3task1, task2, task3ETCD/running/task3Node1Node2Node3task1, task2, task3task1, task2, task3task1, task2, task3execute task346180+700+ 1600APP1. 2. 3. 5