在大数据ETL场景,将Kafka中的消息流转到其他下游服务是很常见的场景,除了常规的消息流转外,很多场景还需要基于消息体内容做判断,然后决定下游服务做何种操作。 该方案实现了通过Kafka中消息Key的内容来判断应该对MongoDB做增、删、改的哪种DML操作。 当Kafka收到消息后,会自动触发函数计算中的函数,接收到消息,对消息内容做判断,然后再操作MongoDB。用户可以对提供的默认函数代码做修改,来满足更复杂的逻辑。 整体方案通过CADT可以一键拉起依赖的产品,并完成了大多数的配置,用户只需要到函数计算和MongoDB控制台做少量配置即可。
FC 实现阿里云 Kafka 消息内容控制 MongoDB DML 操作 目录 目录 文档版本信息.I 法律声明.II 目录.III 最佳实践概述.4 前置条件.1 1.基础环境搭建.2 2.配置 MongoDB.23 2.1.设置白名单.23 2.2.记录 MongoDB连接地址.24 2.3.创建 MongoDB库和集合.25 2.4.查询 MongoDB中的数据.26 3.配置函数计算 FC.28 3.1.登录函数计算 FC...