我们最近将 Snowflake 置于 Okta 之后,所以这是我第一次尝试让 Snowflake 连接在 Airflow 中本地工作。
这是代码,我只是通过添加身份验证器参数进行了更改,但我遗漏了一些东西,请参阅下面的日志:
from snowflake import connector as sfconn
conn = sfconn.connect(
user=self.username,
password=self.password,
account=self.account,
database=self.database,
region=self.region,
role=self.role_name,
autocommit=self.autocommit,
authenticator='externalbrowser'
)
我在气流日志中看到以下内容:
{logging_mixin.py:120} 信息 - 我们无法为您打开浏览器窗口,请手动打开以下网址,然后将您重定向到的网址粘贴到终端中。
{logging_mixin.py:120} 信息 - URL:https://login.xxx.com/app/snowflake/xxxxx/sso/saml?SAMLRequest=blahblah
{logging_mixin.py:120} INFO - 输入 SSO URL 重定向的 URL 至:
{taskinstance.py:1851} 错误 - 任务因异常回溯而失败 (最后一次通话):
文件“/usr/local/lib/python3.8/site-packages/snowflake/connector/auth_webbrowser.py”,第 139 行,在 authenticate 中
url = input("请输入 SSO URL 将您重定向到的 URL:")
EOFError:读取一行时出现 EOF
当我转到日志中提供的 URL 时,我看到
Redirecting to Snowflake
然后我看到无法连接