如何解决如何在MongoDB v3中删除聚合管道的输出JSON关键字中的类型名称?
我正在使用MongoDB Kafka Connector v1.1.0作为源连接器,以从数据库读取数据并执行一些数据转换,然后再将消息发布到Kafka主题中。
但是,问题在于它不支持SMT,因此在发送有效负载之前,我不得不使用MongoDB聚合管道来执行数据转换。
一切都很好,除非数据类型不是字符串,MongoDB会将类型插入为键。
是否有一种方法可以使用MongoDB聚合管道删除类型,使其看起来像是正确构造的JSON?
实际JSON有效负载
{
"messageId":"45581b14-28fe-40cb-a26e-ec7701150830","entityId":{
"$numberLong":"813956"
},"groupId":{
"$numberLong":"151747222"
},"event":"ENTITY_CREATED","payload":"{\"entityId\":813956,\"category\":1,\"timestamp\":\"2020/09/09 11:09:31\"}","timestamp":{
"$date":1599617371132
}
}
所需的JSON有效负载
{
"messageId":"45581b14-28fe-40cb-a26e-ec7701150830","entityId": 813956,"groupId": 151747222,"timestamp": "2020/09/09 11:09:31"
}
P.S。请注意,我正在使用v3,并且无法升级到v4。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。