有人能告诉我如何在无服务器平台(FaaS(中设置Flink以执行事件驱动的操作吗？
我看了Flink函数，它似乎很有前景。有人能澄清一下吗？
-
我需要在FaaS环境中安装什么。当事件(我的s3存储桶中的文件更改(发生时触发flink函数？
-
我没有大数据平台，所以计划在我的无服务器/kubernetesenv中使用flink。
提前感谢！！
要使用StateFun，您通常需要：
- 一个将触发函数的入口
- 将对事件做出反应的实际代码(有状态函数(Dockerized
- 为您的申请提供午餐的方式
具体而言：
-
每个有状态的函数应用程序都以Ingress开始，基本上，Ingress是函数可以响应的事件的漏斗。在你的情况下，你可以使用亚马逊Kinesis作为你的入口，并确保你的S3事件会在那里结束。
-
接下来，您需要熟悉Java或Python中的有状态函数SDK，并编写处理传入事件的逻辑。该阶段的结果将是Docker图像。
-
然后，您需要午餐在(2(中获得的图像，为此您可以使用Kubernetes(您不必(。这里提供了Helm图表以方便您使用，还有一个简单的实用程序来生成必要的k8s资源。