最近实时数仓接到了一个需求，需要实时分析城市天气对订单的影响，并实时调整营销策略。本来是期望特征平台能够有实时天气的topic或者hbase来给我们各个业务线作为公共维表使用的，但是并没有，所以在需求急迫的背景下，想到了通过flink自定义source来获取实时的天气，存入到实时数仓公共维表中。
一、flink主程序
public class HttpAsyncQueryWeather {
public static void main(String[] args) throws Exception {
