代码包下载地址：
1. 新建函数，并设置名称
配置/新增函数，并创建函数名。
2. 配置环境变量
es_address=172.17.16.xx:9xx //ES 端口地址
es_index_name=tabor //ES Index名
es_password=xxxx //ES 密码
es_user=elastic //ES 用户名
kafka_address=shanghai-kafka-0.xxxxntcs.com:32169 // DTS 侧 Ckafka 地址
kafka_group_name=consumer-gxxi6o2q6f-tabor // DTS 侧 Ckafak group name
kafka_group_password=xxxx // DTS 侧 Ckafak 密码
kafka_group_user=account-subsxxq6f-tabor // DTS 侧消费者用户名
kafka_topic_name=topic-subsxx2q6f-cdb-8rfubz5w // DTS 侧消费者Topic
region=ap-shanghai // 云函数地域3. 配置私有网络
配置与ES/DTS相同的VPC网络环境
4. 配置 Timer 触发器
推荐五分钟触发一次，超时时间也可改为 5 分钟
5. 查看日志执行情况
- 登陆 Kibana 查看转储日志
