有人能告诉我如何在我的无服务器平台（faas）中设置flink来执行事件驱动操作吗？我看了flink函数，它看起来很有前途。有人能澄清一下吗？我需要在faas env中安装什么。当一个事件（我的s3 bucket中的文件更改）发生时触发flink函数？我没有大数据平台，因此计划在我的无服务器/kubernetes env中使用flink。提前谢谢！！
inb24sb21#
要使用statefun，您通常需要：会触发函数的入口。将对事件（有状态函数）作出React的实际代码已停靠一种解决申请的方法明确地：每个有状态函数应用程序都从入口开始，基本上这是一个事件漏斗，您的函数可以对其作出React。在您的例子中，您可以使用amazon kinesis作为入口，并确保您的s3事件将在那里结束。接下来，您需要熟悉java或python中的有状态函数sdk，并编写处理传入事件的逻辑。这个阶段的结果将是一个 Docker 的形象。然后，您需要使用在（2）中获得的图像，为此您可以使用kubernetes（您不必这样做）。有舵图为您提供方便和一个简单的实用工具，以生成必要的k8s资源。
1条答案
按热度按时间inb24sb21#
要使用statefun，您通常需要：
会触发函数的入口。
将对事件（有状态函数）作出React的实际代码已停靠
一种解决申请的方法
明确地：
每个有状态函数应用程序都从入口开始，基本上这是一个事件漏斗，您的函数可以对其作出React。在您的例子中，您可以使用amazon kinesis作为入口，并确保您的s3事件将在那里结束。
接下来，您需要熟悉java或python中的有状态函数sdk，并编写处理传入事件的逻辑。这个阶段的结果将是一个 Docker 的形象。
然后，您需要使用在（2）中获得的图像，为此您可以使用kubernetes（您不必这样做）。有舵图为您提供方便和一个简单的实用工具，以生成必要的k8s资源。