python - 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 的 redis sink：https ://flink-packages.org/packages/apache-bahir-redis-connector 。

如果您使用 google 环顾四周（或者如果您在 github 上搜索），您会发现有几个人已经实现了简单的 mongodb sinks，您可能会发现它们是可行的，具体取决于您的要求。

至于使这些连接器与 PyFlink 一起使用，我不确定。