如何在Airflow变量UI中初始化Map<String,List<String>>类型变量？

1. 在Airflow变量UI中配置值 #

Airflow变量UI不支持直接使用Scala/Java风格的Map(...)语法，必须用标准JSON格式定义目标结构。在变量值输入框中填入：

{"stringValue": ["abc", "def", "ghi"]}

注意：务必保证JSON格式合规——键和字符串值用双引号，列表元素用方括号包裹。

2. 在DAG中读取并解析变量 #

使用Variable.get()时，需要指定deserialize_json=True参数，让Airflow自动将JSON字符串反序列化为Python字典（对应你需要的Map<String, List>结构）。示例代码：

from airflow.models import Variable

# 读取变量并自动反序列化为字典
my_map_var = Variable.get("your_variable_name", deserialize_json=True)

# 访问对应列表值
target_list = my_map_var.get("stringValue")  # 结果为 ["abc", "def", "ghi"]

补充说明 #

• 你之前尝试的Map(...)写法属于Scala/Java语法，Airflow变量系统无法识别，必须替换为JSON格式。
• 如果未指定deserialize_json=True，Variable.get()会返回原始JSON字符串，此时可以手动用json.loads()解析：

import json
from airflow.models import Variable

raw_var = Variable.get("your_variable_name")
my_map_var = json.loads(raw_var)

内容的提问来源于stack exchange，提问作者shady_vaib