寻找带有 Kinesis 的 Pyflink 示例

Question

我有一个 kinesis 流，我想使用 pyflink 收听它。

我已经为 python3 安装了 Apapache-flink@1.12.2 包， 我看到了一些在 python 中使用 Kinesis 的例子（比如这个：https://stackoverflow.com/a/22403036） 并从以下内容中了解到：https://stackoverflow.com/a/65018578/1322801，这个版本应该支持连接到 Kinesis。

我找不到使用它的示例，有人知道为此目的的好教程吗？

谢谢！

Answer 1

This 就是你要找的东西。