jacob-mathison/doczyai-pipelines
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Activity

Changed the layer and update db interface code

Browse Source
This commit is contained in:
Umang Mistry
2024-06-12 17:19:33 -05:00
parent e594443f1a
commit fbfc4d7bc8
2 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
textract-pipeline/src/lambda-layer/snowflake-connector/snowflake-lambda-layer.zip → textract-pipeline/src/lambda-layer/snowflake-connector/sf-39-layer.zip
BIN
View File
Binary file not shown.
textract-pipeline/src/lambda/database-interface/index.py
+1 -1
View File
@@ -128,7 +128,7 @@ def get_snowflake_db_connection(secrets_name: str):
logger.info(f'Using credentials: account={account}, user={user}, password=***, database={database}, '
f'warehouse={warehouse}')
snowflake_connection = snowflake.connector.connect(account=account, user=user, password=password, database=database,
warehouse=warehouse, autocommit=True, schema='STG')
warehouse=warehouse,role=role, autocommit=True, schema='STG')
logger.info(snowflake_connection)
cursor = snowflake_connection.cursor()
cursor.execute("SELECT * FROM STG.DIM_AUDIT LIMIT 10;")