可以使用json.dumps将字符串转换为json格式,然后在xcom中存储该格式的字符串。在需要使用xcom值的地方,使用json.loads将字符串转换回列表格式。
示例代码:
将字符串转换为json格式并存储在xcom中:
from airflow.models import Variable
import json
my_list = ['item1', 'item2', 'item3']
my_list_json = json.dumps(my_list)
Variable.set('my_xcom', my_list_json)
从xcom中获取json格式字符串并将其转换回列表格式:
from airflow.models import Variable
import json
my_list_json = Variable.get('my_xcom')
my_list = json.loads(my_list_json)
print(my_list)
# ['item1', 'item2', 'item3']