码农知识堂 - 1000bd
  •   Python
  •   PHP
  •   JS/TS
  •   JAVA
  •   C/C++
  •   C#
  •   GO
  •   Kotlin
  •   Swift
  • DolphinScheduler 进阶(工作流传参)


    文章目录

    • 本地参数和全局参数
      • 本地参数
      • 全局参数
    • 参数传递
    • 参数优先级

    本地参数和全局参数

    DolphinScheduler 支持对任务节点进行灵活的传参,任务节点可通过 ${参数名} 引用参数值。

    本地参数

    本地参数是指只针对单个任务节点有效的参数。

    (1)修改 helloworld 工作流 Node-A 节点如下

    在这里插入图片描述

    ➢ dt:参数名
    ➢ IN/OUT:IN 表示向当前节点传参,OUT 表示向下游节点传参
    ➢ VARCHAR:参数值类型
    ➢ 2022-09-20:参数值

    (2)保存工作流并运行,查看 Node-A 输出日志。

    在这里插入图片描述

    全局参数

    全局参数是指针对整个工作流的所有任务节点都有效的参数。

    (1)修改 helloworld 工作流每个任务节点如下

    节点 A 配置

    在这里插入图片描述

    节点 B 配置

    在这里插入图片描述

    节点 C 配置

    在这里插入图片描述

    (2)保存工作流,并设置全局参数

    在这里插入图片描述

    (3)执行工作流,查看三个任务节点输出日志。

    Node-A

    在这里插入图片描述

    Node-B

    在这里插入图片描述

    Node-C

    在这里插入图片描述

    参数传递

    DolphinScheduler 支持上游任务节点向下游任务节点传参。目前支持这个特性的任务类型有:Shell、SQL、Procedure。

    以下案例使用 Shell 类型的任务节点进行演示。

    1)设置上游节点 Node-A

    在这里插入图片描述

    注:echo '${setValue(key=value)}'为固定写法

    2)设置下游节点 Node-C

    在这里插入图片描述

    3)查看输出日志

    可以看到对应节点日志中输出了其调用参数的值。

    在这里插入图片描述

    参数优先级

    一个任务节点引用的参数可能来自三种类型:分别是全局参数 、上游任务传递的参数、本地参数。因为参数的值存在多个来源,当参数名相同时,就需要考虑参数优先级的问题。

    DolphinScheduler 参数的优先级从低到高为: 全局参数 <上游任务传递的参数 <本地参数。 在上游任务传递的参数的情况下,由于上游可能存在多个任务向下游传递参数。当上游传递的参数名称相同时:下游节点会优先使用值为非空的参数。如果存在多个值为非空的参数,则按照上游任务的完成时间排序,选择完成时间最早的上游任务对应的参数。

  • 相关阅读:
    初始化一个Gin框架的Go-Web项目
    Stable Diffusion 2.0 来了
    springboot+人事信息管理系统 毕业设计-附源码221507
    咪咕MGV2000KL南传_S905L3B_MT7668线刷固件包
    接口测试框架基于模板自动生成测试用例!
    构建LangChain应用程序的示例代码:31、连接大型语言模型与机器学习社区的系统-HuggingGPT教程
    @Autowire、@Recourse用啥?
    Unreal UnLua + Lua Protobuf
    基于FreeCAD的dxf转机械手代码的一种实现方法
    SpringMVC使用(注解、获取各种参数的方式、视图模板、文件上传下载、国际化、RestFul)
  • 原文地址:https://blog.csdn.net/weixin_45417821/article/details/127091817
  • 最新文章
  • 攻防演习之三天拿下官网站群
    数据安全治理学习——前期安全规划和安全管理体系建设
    企业安全 | 企业内一次钓鱼演练准备过程
    内网渗透测试 | Kerberos协议及其部分攻击手法
    0day的产生 | 不懂代码的"代码审计"
    安装scrcpy-client模块av模块异常,环境问题解决方案
    leetcode hot100【LeetCode 279. 完全平方数】java实现
    OpenWrt下安装Mosquitto
    AnatoMask论文汇总
    【AI日记】24.11.01 LangChain、openai api和github copilot
  • 热门文章
  • 十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧!!!
    奉劝各位学弟学妹们,该打造你的技术影响力了!
    五年了,我在 CSDN 的两个一百万。
    Java俄罗斯方块,老程序员花了一个周末,连接中学年代!
    面试官都震惊,你这网络基础可以啊!
    你真的会用百度吗?我不信 — 那些不为人知的搜索引擎语法
    心情不好的时候,用 Python 画棵樱花树送给自己吧
    通宵一晚做出来的一款类似CS的第一人称射击游戏Demo!原来做游戏也不是很难,连憨憨学妹都学会了!
    13 万字 C 语言从入门到精通保姆级教程2021 年版
    10行代码集2000张美女图,Python爬虫120例,再上征途
Copyright © 2022 侵权请联系2656653265@qq.com    京ICP备2022015340号-1
正则表达式工具 cron表达式工具 密码生成工具

京公网安备 11010502049817号