airflow - 如何在气流中创建 Hive 连接到特定数据库？

Question

我正在尝试在气流中创建 Hive 连接以指向特定的数据库。我试图在 HiveHook 中找到参数，并在额外选项中尝试了以下内容。

{"db":"test_base"}  {"schema":"test_base"} and {"database":"test_base"}

但看起来没有任何作用，并且总是指向默认数据库。

有人可以帮我指出我们可以在 extra_options 中传递的可能参数是什么吗？

标签： airflowairflow-scheduler