使用Flink消费kafka中的数据,统计商城每分钟的GMV,将结果存入redis中(value 为字符串格式,仅存 GMV),key 为 store_gmv,使用 redis cli 以 get key 方式获 取 store_gmv 值,将每次截图粘贴至对应报告中(每分钟查询一次,查询 3 次)。
时间: 2023-03-10 17:51:25 浏览: 305
可以使用Flink从Kafka消费数据,统计商城每分钟的GMV,并将统计结果以字符串格式的形式存入Redis,key为store_gmv,使用Redis cli以get key的方式获取store_gmv的值,并每分钟查询3次,将每次截图粘贴至对应报告中。
相关问题
scala2.12版本编写Flink1.14消费kafka中的数据,统计商城每分钟的GMV,将结果存入redis中(value为字符串格式,仅存GMV),key为store_gmv,使用redis cli以get key方式获取store_gmv值,
可以的,这个问题是关于技术的,我可以回答你。你可以使用Flink1.14的Kafka Consumer API消费Kafka中的数据,然后使用Flink的窗口操作进行每分钟的GMV统计。最后,你可以使用Redis的Java客户端将GMV值存储到Redis中。使用Redis cli以get key方式获取store_gmv值即可。希望这个回答对你有所帮助。
使用Flink消费kafka中的数据,统计商城每分钟的GMV,将结果存入redis中
好的,这个问题比较简单。您可以使用 Flink 的 Kafka Connector 来消费 Kafka 中的数据,然后对 GMV 进行统计,可以使用 Flink 的窗口操作,比如 Tumbling Window 或者 Sliding Window,最后将统计结果存入 Redis 中。如果您需要更详细的操作步骤,可以参考 Flink 官方文档或者相关的博客文章。
阅读全文