반응형
실행
. ./venv/bin/activate
pip install snowflake-connector-python
pip install "snowflake-connector-python[pandas]"
Snowflake Connector for Python
// models.py
import os
import snowflake.connector
AWS_ACCESS_KEY_ID = os.getenv('<KEY_ID>')
AWS_SECRET_ACCESS_KEY = os.getenv('<ACCESS_KEY>')
conn = snowflake.connector.connect(
user='<USER>',
password='<PW>',
account='<ACCOUNT>'
)
cs = conn.cursor()
def getTestDataAll() :
query = "<SELECT * FROM IRON_S3.PUBLIC.TEST_TABLE>"
data = conn.cursor().execute(query)
data_df = data.fetch_pandas_all()
print(data_df)
return data_df
결과
728x90
반응형
'Data > Data Engineering' 카테고리의 다른 글
빅데이터 프레임워크 2주차 비게이터 기반 기술 - OS 및 가상화 (0) | 2024.03.21 |
---|---|
데이터 중심 애플리케이션 설계 : 1장 신뢰할 수 있고 확장 가능하며 유지보수하기 쉬운 애플리케이션 (0) | 2024.03.21 |
[Snowflake] S3 Load Data (0) | 2024.03.06 |
[Kafka] Kafka-python 설치 (0) | 2024.03.06 |
[Airflow] Airflow 설치하기(pip) (0) | 2024.03.06 |