Kri*_*una 3 sqlalchemy snowflake-cloud-data-platform
我有以下代码,我有帐户、用户名、密码等,但我仍然看到以下错误:
raise error_class( sqlalchemy.exc.ProgrammingError: (snowflake.connector.errors.ProgrammingError) 251001: 必须指定帐户
我也尝试过更改函数engine中的变量,created_db_engine如下所示,但我看到了相同的错误:
engine = snowflake.connector.connect(
user='USER',
password='PASSWORD',
account='ACCOUNT',
warehouse='WAREHOUSE',
database='DATABASE',
schema='SCHEMA'
)
Run Code Online (Sandbox Code Playgroud)
这是我的代码
import pandas as pd
from snowflake.sqlalchemy import URL
from sqlalchemy import create_engine
import snowflake.connector
from snowflake.connector.pandas_tools import write_pandas, pd_writer
from pandas import json_normalize
import requests
df = 'my_dataframe'
def create_db_engine(db_name, schema_name):
engine = URL(
account="ab12345.us-west-2.snowflakecomputing.com",
user="my_user",
password="my_pw",
database="DB",
schema="PUBLIC",
warehouse="WH1",
role="DEV"
)
return engine
def create_table(out_df, table_name, idx=False):
url = create_db_engine(db_name="db", schema_name="skm")
engine = create_engine(url)
connection = engine.connect()
try:
out_df.to_sql(
table_name, connection, if_exists="append", index=idx, method=pd_writer
)
except ConnectionError:
print("Unable to connect to database!")
finally:
connection.close()
engine.dispose()
return True
print(df.head)
create_table(df, "reporting")
Run Code Online (Sandbox Code Playgroud)
鉴于SqlAlchemy 的 Snowflake 文档,您的帐户参数不应包含Snowflakecomputing.com。
因此,您应该尝试使用ab12345.us-west-2,连接器将自动为您附加域部分。
| 归档时间: |
|
| 查看次数: |
3342 次 |
| 最近记录: |