Spaces:
Sleeping
Sleeping
File size: 2,395 Bytes
478dec6 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 | # import os
# import dotenv
# dotenv.load_dotenv()
# import asyncpg
# # from datetime import datetime
# async def fetch_data(query:str):
# try:
# conn = await asyncpg.connect(user=os.environ.get("causalogy--pg--user"),
# password=os.environ.get("causalogy--pg--password"),
# database=os.environ.get("causalogy--pg--name"),
# host=os.environ.get("causalogy--pg--host"),
# port=os.environ.get("causalogy--pg--port"))
# values = await conn.fetch(query)
# print(f"""✅ Fetching data succeeded!""")
# return values
# except Exception as E:
# print(f"""❌ Error when Fetching data, {E}""")
# finally:
# await conn.close()
# async def execute_query(query:str):
# try:
# conn = await asyncpg.connect(user=os.environ.get("causalogy--pg--user"),
# password=os.environ.get("causalogy--pg--password"),
# database=os.environ.get("causalogy--pg--name"),
# host=os.environ.get("causalogy--pg--host"),
# port=os.environ.get("causalogy--pg--port"))
# values = await conn.execute(query)
# print(f"""✅ Executing query succeeded!""")
# return True
# except Exception as E:
# print(f"""❌ Error when Executing query, {E}""")
# return False
# finally:
# await conn.close()
# async def execute_insert_binary(filename: str, file_content: bytes, query:str="""INSERT INTO cv_raw (filename, file_content) VALUES ($1, $2);"""):
# conn = None
# try:
# conn = await asyncpg.connect(
# user=os.environ.get("causalogy--pg--user"),
# password=os.environ.get("causalogy--pg--password"),
# database=os.environ.get("causalogy--pg--name"),
# host=os.environ.get("causalogy--pg--host"),
# port=os.environ.get("causalogy--pg--port")
# )
# await conn.execute(query, filename, file_content)
# print(f"✅ Successfully inserted {filename} into cv_raw")
# except Exception as E:
# print(f"❌ Error when executing insert: {E}")
# finally:
# if conn:
# await conn.close() |