通量解析器 Fluxio是使用Python构建工作流的框架。 这是解析器组件。 它的工作是将Fluxio项目的Python DSL解析为内存中的表示形式。 其他组件将解析的项目转换为可部署的工件。 Fluxio DSL Fluxio采用了用Python语法编写的 。 这意味着文件的是从源代码解析的,而不是由Python解释器直接执行的模块。 Fluxio项目文件包含: 名为“ main”的模块级功能,用于定义状态机逻辑。 此功能将在以后转换为时进行解析。 为了清楚起见,该函数应定义单个位置arg数据,但从技术上讲并不重要。 此变量表示状态机执行的输入数据,在ASL中称为$。 见下文如何在Fluxio语法定义的各种状态节 如果状态机需要任何任务状态,则应定义一个或多个模块级类。 每个类都必须具有唯一的PascalCased名称。 每个类都必须从继承。 每个类都应定义一个run方