腾讯云消息队列 CKafka 新建数据流出任务 - 解析内部 JSON 结构
文档简介：
本文以一个数据示例介绍 CKafka 连接器提供的解析数据内部 JSON 结构的功能。
咨询热线：400-826-7010，为您提供专业的售前咨询，让您快速了解云产品，助您轻松上云！
微信咨询
免费试用、价格特惠
解析内部 JSON 结构
1. 输入带嵌套 JSON 格式的原始数据，以下为一个示例。
{"@timestamp": "2022-02-26T22:25:33.210Z","beat": {"hostname": "test-server","ip": "6.6.6.6","version": "5.6.9"},"input_type": "log","message": "{\"userId\":888,\"userName\":\"testUser\"}","offset": 3030131}
2. 解析结果如下：
3. DIP 处理方式：通过对该字段选择 MAP 操作来对其进行解析，从而把特定字段解析为 JSON 格式：
