DataWorks中如果Python UDF有输出参数,并需要把这个参数传递给下游节点或赋值节点使用,可以通过以下方式调用:

在Python代码中使用op.set_outputs()函数定义输出参数:
python
Copy
import pyodps

引入op

from pyodps.df import DataFrame

def my_udf(df):

处理逻辑

result = ...

定义输出参数res

op = pyodps.task.get_sample_python_operator()
op.set_outputs(res=result)

if name == 'main':
my_udf()
在DataWorks任务配置中,将Python节点的输出链接到下游节点:
下游节点可以使用${python.res}引用Python输出参数res

可以看下使用者部分 https://help.aliyun.com/zh/dataworks/user-guide/configure-input-and-output-parameters?spm=a2c4g.11186623.0.i1#3e62dc7026onl:~:text=%E6%97%A0-,%E4%B8%8B%E6%B8%B8,-%E8%8A%82%E7%82%B9%E4%BD%BF%E7%94%A8%E8%BE%93%E5%85%A5 不过为啥是传递给赋值节点，赋值节点有节点上下文 输入参数 是哪里阻塞了吗，此回答整理自钉群“DataWorks交流群(答疑@机器人)”