小编CJL*_*L89的帖子

有谁知道从 Airflow 中的 DAG 更新变量（但采用 JSON 格式）的语法？

现在我有这个：

Variable.set(f"update_{kwargs['table_id']}", *last_update)

这会将变量更新为：

• updated_giftcard_id 0
• updated_order_id 0

但这会产生不可扩展的新变量。

理想情况下，我想更新相同的变量并以 JSON 格式传递它们：

例如："last_ids": {"updated_giftcard_id:" "0", "updated_order_id:" "1", etc}"

我尝试传递一些参数，例如Variable.set(key="updated_giftcard_id", value="0", serialize=True)，但无法正常工作，因为它抱怨我传递了太多参数。

提前致谢！