在Kubernetes的Apache Flink

Question

请让我知道如何在我的无服务器平台( Serverless platform，FaaS)中设置Flink来执行事件驱动的操作。

我看了Flink函数，看起来很有希望。有人能在下面澄清一下吗？

1. 我需要在我的FaaS env中安装什么。要在发生事件(我的s3桶中的文件更改)时触发flink函数？
2. 我没有大数据平台，所以计划在我的无服务器/kubernetes env中使用flink。

提前谢谢！！

Answer 1

要使用StateFun，通常需要：

1. 一个会触发函数的入侵。
2. 对事件(有状态函数)作出反应的实际代码
3. 一种午餐申请的方法

具体地说：

1. 每个有状态的函数应用程序都以一个侵入开始，基本上这是一个事件的漏斗，您的函数可以对这些事件做出反应。在您的示例中，您可以使用亚马逊动态作为您的入口处，并确保您的S3事件将在那里结束。
2. 接下来您需要的是让自己熟悉Java或Python中的有状态函数SDK，并编写处理传入事件的逻辑。这个阶段的结果将是一个码头形象。
3. 然后，您需要午餐在(2)处获得的图像，为此您可以使用Kubernetes (您不必这么做)。为了您的方便，有一个舵图和一个简单效用来生成必要的k8s资源。