Flink 支持开发 Python 类型任务。您可以自行编写 Python 程序，并将 Python 文件上传到资源库，即可在平台上开发 Python 任务。
本文为您介绍流式类型 Python 任务的开发流程。如需了解 Batch Python 任务，请参见 开发 Flink Batch Python 任务。

前提条件

• 项目管理员（Project_Admin）已经在项目内创建好 Flink 资源池，请参见创建资源池。
• 开发人员需提前编写 Python 程序，并将 Python 文件上传到资源库。如何上传文件，请参见上传资源文件。可以参考如下 Python 代码内容：

注意：以下代码文件名不能为 pyflink 等和 flink python 库冲突的名字，否则会造成任务失败等原因

from pyflink.datastream import StreamExecutionEnvironment

def main():
    # 创建执行环境
    env = StreamExecutionEnvironment.get_execution_environment()
    # 创建一个数据流，元素为 1, 2, 3, 4, 5
    data_stream = env.from_collection([1, 2, 3, 4, 5])
    # 对数据流中的每个元素进行加 1 操作
    result_stream = data_stream.map(lambda x: x + 1)
    # 打印结果
    result_stream.print()
    # 执行程序
    env.execute("Simple PyFlink Example")

if __name__ == "__main__":
    main()

功能限制

目前仅 Flink 1.17-volcano 版本支持 Flink Python 任务。

步骤一：创建 Flink Python 任务

1. 登录流式计算 Flink 版控制台。
2. 在顶部菜单栏选择目标地域。
3. 在左侧导航栏选择项目管理，在搜索框中根据项目名称进行模糊搜索，然后单击项目区块进入项目。
4. 在项目左侧导航栏选择作业开发 > 作业开发。
5. 在作业开发页面单击加号按钮，创建任务。
   您也可以选择目标文件夹，直接在该文件夹中创建任务；也可以直接单击引导页面下的 Flink Python 作业。
6. 在创建作业对话框，设置作业名称、存储位置、引擎版本等关键参数，然后单击确定。

6. 在任务配置区域，设置任务关键参数。

7. 任务开发和配置完成后，单击保存。

步骤二：上线任务

开发与生产隔离，当任务开发者完成任务开发后，可以将任务上线到生产环境。

1. 在作业开发栏目下查找并单击目标任务，单击上线。
2. 在任务上线设置对话框，选择运行资源池、设置任务优先级和调度策略，然后单击确定。
   系统会提示任务上线成功，可以前往任务管理页面查看。

步骤三：启动任务

任务开发者将任务上线到生产环境后，由运维人员启动任务。

1. 在项目左侧导航栏选择任务运维 > 任务管理。

2. 在任务列表页面，选择额目标任务，单击操作列中的启动。

3. 在启动任务对话框，选择任务启动方式，然后单击确定。
   

   配置	说明
   启动方式	请根据实际情况选择任务启动方式： 从最新状态启动：以最新的 Checkpoint 或 Savepoint 启动。 全新启动：不使用 Checkpoint 或 Savepoint，直接启动。 指定快照启动：指定目标快照（Savepoint）启动。 说明 首次上线的任务，只能是全新启动方式。
   参数配置	任务携带在开发侧的并行度、TaskManager 和 JobManager 的资源配置。在启动任务时支持您更新配置并快速生效。 说明 更新参数配置并启动任务后，将新增一个任务版本，并将最新配置同步到任务开发侧。 并行度：任务全局并发数。 单个 TaskManager CPU 数：单个 TaskManager 的 CPU 核数。 单个 TaskManager 内存大小：单个 TaskManager 占用的内存大小。 单个 TaskManager slot 数：单个 TaskManager 的 Slot 数量。 JobManager CPU 数：单个 JobManager 的 CPU 核数。 JobManager 内存大小：单个 JobManager 占用的内存大小。
   更多设置	在任务开发变更时新增或修改算子，可能会导致任务无法从快照恢复，此时您可以选择启用允许忽略部分算子状态功能，保证任务能正常运行。 注意 仅当选择指定快照启动或从最新状态启动方式时，支持勾选忽略部分算子状态。 当您选择全新启动方式时，不支持忽略算子状态。

步骤四：查看 Flink UI

任务在生产环境上正常运行后，您可以在 Flink UI 界面了解任务运行、TaskManager、JobManager 的详细信息。

1. 在项目左侧导航栏选择任务运维 > 任务管理。
2. 在任务列表页面筛选目标任务，单击操作列下的 Flink UI。
   浏览器将会自动打开 Apache Flink Dashboard 页面。
3. 在 Apache Flink Dashboard 页面，查看任务运行详情。