一、kafka输入
选择对应的数据服务topic。
二、json格式化
初步解析，准备过滤脏数据条件。
三、条件过滤
过滤脏数据，只保留新增数据进行推送。
四、json格式化
对过滤后的数据进一步解析。
五、字段处理
对解析后的数据进行函数处理。
六、微信群机器人
配置机器人Key，配置消息内容。
七、推送企业微信自建应用
任务配置图如下：
其余配置与上述相同，不赘述。企业微信消息推送，分别配置好corpid、agentid、secret，配置消息推送内容。
（agentid和secret在自建应用中找）
