### ESTABLISHING CONNECTION TO SNOWFALKE
#Installing libraries
##pip install snowflake-connector-python==2.3.8
#Importing all the required libraries
import getpass
import snowflake.connector
import pandas as pd
#Getting user imputs to establish connection to snowflake
USER = input("PLEASE ENTER YOUR SNOWFLAKE USERNAME ")
PASSWORD = getpass.getpass("ENTER YOUR SNOWFLAKE PASSWORD ")
ACCOUNT = input("PLEASE ENTER YOUR SNOWFLAKE ACCOUNT NAME ")
#create snowflake database connection
conn= snowflake.connector.connect(
user=USER,
password=PASSWORD,
account=ACCOUNT,
warehouse='COHORT_XL',
database = 'IMV_IMMUNOVACCINE_INC_DLBCL_RITUXIMAB_ANY_ANTHRACYCLINE',
schema = 'SANDBOX'
)
cur=conn.cursor()
#Checking the conenction
cur
import pandas as pd
original = r"C:\Users\aseem.malik\Downloads\TX.csv" # <- Replace with your path.
delimiter = "," # Replace if you're using a different delimiter.
total = pd.read_csv(original, sep = delimiter)
write_pandas(conn, total, 'test')熊猫的写作功能不起作用,一直给出以下的错误。
Unable to find a usable engine; tried using: 'pyarrow', 'fastparquet'.
A suitable version of pyarrow or fastparquet is required for parquet support.
Trying to import the above resulted in these errors:
- Missing optional dependency 'pyarrow'. pyarrow is required for parquet support. Use pip or conda to install pyarrow.
- Missing optional dependency 'fastparquet'. fastparquet is required for parquet support. Use pip or conda to install fastparquet.发布于 2022-04-25 17:10:55
请安装这些软件包:
pip install pyarrow
pip install fastparquethttps://stackoverflow.com/questions/72003105
复制相似问题