感谢Xingbo的回复，稍微补充一点：所有Table & SQL支持的connector都可以用在PyFlink中。
redis的connector没有直接在Flink的代码库里提供，这里有一个，应该也可以用：https://github.com/apache/bahir-flink/tree/master/flink-connector-redis <https://github.com/apache/bahir-flink/tree/master/flink-connector-redis> 关于如何在PyFlink中使用connector，可以参考文档：https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/python/table-api-users-guide/python_table_api_connectors.html > 在 2020年12月17日，上午9:52，Xingbo Huang <[email protected]> 写道： > > Hi, > > 据我所知，flink没有提供对redis connector的官方支持[1]，你需要根据官方提供的接口来自定义你的redis > connector，关于如何自定义connector，你可以参考文档[2] > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors/ > [2] > https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/sourceSinks.html > > Best, > Xingbo > > > 消息室 <[email protected]> 于2020年12月17日周四 上午9:33写道： > >> 您好： >> >> >> 我们项目组计划使用pyflink，有幸拜读了您的博客，我想请教一下当前1.12.0版本的pyflink的sink是否支持redis >> connector?感谢！ >> 如不支持，有何建议方式？
