Python 节点

综述

Python 任务类型，用于创建 Python 类型的任务并执行一系列的 Python 脚本。worker 执行该任务的时候，会生成一个临时python脚本， 并使用与租户同名的 linux 用户执行这个脚本。

点击项目管理-项目名称-工作流定义，点击”创建工作流”按钮，进入DAG编辑页面。

工具栏中拖动 到画板中，即可完成创建。

任务样例

简单打印一行文字

该样例模拟了常见的简单任务，这些任务只需要简单的一两行命令就能运行起来。我们以打印一行日志为例，该任务仅会在日志文件中打印一行 “This is a demo of python task”

print("This is a demo of python task")

使用自定义参数

该样例模拟了自定义参数任务，为了更方便的复用已有的任务，或者面对动态的需求时，我们会使用变量保证脚本的复用性。本例中，我们先在自定义脚本 中定义了参数 “param_key”，并将他的值设置为 “param_val”。接着在”脚本”中使用了 print 函数，将参数 “param_key” 打印了出来。当我们保存 并运行任务后，在日志中会看到将参数 “param_key” 对应的值 “param_val” 打印出来。

print("${param_key}")

注意事项

None

• 关于 Apache DolphinScheduler
  • 简介
  • 特性
  • 软硬件环境建议配置
  • 名词解释
• 快速上手
  • 快速上手
  • Docker 部署(Docker)
• 功能介绍
  • 应用首页
  • 项目管理
    • 项目列表
    • 工作流定义
    • 工作流实例
    • 任务实例
    • 任务定义
  • 任务类型
    • Appendix
    • Shell
    • SubProcess
    • Dynamic
    • Dependent
    • Stored Procedure
    • SQL
    • Spark
    • MapReduce
    • Python
    • Flink
    • HTTP
    • DataX
    • Sqoop
    • Pigeon
    • Conditions
    • Switch
    • SeaTunnel
    • Amazon EMR
    • Apache Zeppelin
    • Jupyter
    • Hive CLI
    • Kubernetes
    • MLflow
    • Openmldb
    • DVC
    • Dinky
    • Java
    • SageMaker
    • ChunJun
    • Pytorch
    • Amazon DMS
    • AWS Datasync
    • Kubeflow
    • Apache Linkis
    • SSH
    • Vertica
  • 参数
    • 内置参数
    • 全局参数
    • 本地参数
    • 项目级别参数
    • 参数传递
    • 参数优先级
    • 文件参数传递
    • 启动参数
  • 数据源中心
    • MySQL
    • PostgreSQL
    • HIVE
    • SNOWFLAKE
    • KYUUBI
    • Spark
    • Amazon Athena
    • Azure SQL Database
    • Redshift
    • Oracle
    • Trino
    • StarRocks
    • DAMENG
    • OceanBase
    • SSH
    • Databend
    • HANA
    • Doris
  • 告警
    • 告警组件向导
    • Email
    • Telegram
    • 钉钉
    • 企业微信
    • WebexTeams
    • Script 脚本
    • HTTP 告警
    • 飞书
    • Slack
    • 阿里云-语音告警
  • 资源中心
    • 简介
    • 配置详情
    • 文件管理
    • UDF 管理
    • 任务组管理
  • 监控中心
  • 安全中心
    • 安全中心（权限系统）
    • 认证方式
  • 指标相关
    • 指标（Metrics）
  • 数据质量
  • 远程日志存储
  • 升级
    • 不向前兼容的更新
    • 升级步骤
  • 扩/缩容
  • Demo
• 部署指南
  • 单机部署 (Standalone)
  • 伪集群部署(Pseudo-Cluster)
  • 集群部署(Cluster)
  • Kubernetes部署(Kubernetes)
  • 集成
    • 基于Rainbond部署(Cluster)
• 架构设计
  • 元数据文档
  • 架构设计
  • 配置文件
  • 任务结构
  • 负载均衡
  • 缓冲
• API
  • API 调用
  • PyDolphinScheduler
  • 健康检查
• 贡献指南
  • SPI
    • Alert SPI
    • Datasource SPI
    • Registry SPI
    • Task SPI
  • 环境搭建
  • 前端开发
• DSIP
  • DSIP