我是PyFlink的新手。
最近，我使用PyFlink完成了一个从Kafka读取流数据并将其插入另一个Kafka的功能。
现在，我想将数据推送到mongodb和redis中。但我阅读了这些文件，在搜索引擎上搜索了这个问题，并没有得到任何有用的解决方案。
在文档中，有一些与Kafka、文件系统等的连接器。似乎没有mongodb和redis的解决方案。
那么，如何使用PyFlink将数据推送到mongodb和redis？
首先感谢您的帮助！！
mongodb或redis没有官方的Flink连接器。
Apache Bahir项目确实为Flink提供了一个redis接收器：https://flink-packages.org/packages/apache-bahir-redis-connector.
如果你使用谷歌四处搜索(或者在github上搜索(，你会发现有几个人已经实现了简单的mongodb接收器，根据你的需求，你可能会觉得这些接收器是可行的。
至于让这些连接器与PyFlink一起工作，我不确定。