PyFlink -如何使用PyFlink推送数据到mongodb和redis？

Question

我是PyFlink的新手。

最近，我使用PyFlink完成了一个功能，从Kafka读取流数据，并将其插入到另一个Kafka中。

现在，我想将数据推送到mongodb和redis中。但是我阅读了文档并在搜索引擎上搜索了这个问题，我没有得到任何有用的解决方案。

在文档中，有一些与Kafka，文件系统等的连接器。似乎还没有针对mongodb和redis的解决方案。

那么，如何使用PyFlink向mongodb和redis推送数据呢？

首先感谢您的帮助！

Answer 1

mongodb或redis没有官方的Flink连接器。

Apache Bahir项目确实有一个针对Flink：https://flink-packages.org/packages/apache-bahir-redis-connector的redis接收器。

如果您使用google查看(或者在github上搜索)，您会发现有几个人实现了简单的mongodb接收器，您可能会发现它们是可行的，这取决于您的需求。

至于让这些连接器与PyFlink一起工作，我不太确定。