python - 如何在 Airflow Dag 脚本中捕获从 Python 类返回的值？

Question

我有一个 python 类，它实际上返回一组值（两个字符串和一个列表）。我需要在 Airflow Dag 脚本中捕获这些值，然后将这些值填充到字典中。很高兴知道是否有人遇到过一种方法来存储从 Python 类返回的值Airflow？

例如，我有一个类 X()，它有一个方法 Y()，它返回这 3 个值。那么我可以做类似下面的事情来捕获这些值Airflow吗？

x = X() 
val1, val2, val3 = x.Y() # to capture the values

另外，我应该使用哪种 Airflow 运算符来实现这一点（例如 Bash 或 Python 运算符）？

标签： pythonpython-3.xairflow

Answer 1

使用气流变量

d = {'x':'y'}
Variable.set('my_data_key',json.dumps(d))