Expose Snowflake Data by creating Python API
Prerequisite:
--------------------
Creating Python API using Flask
• Creating Python API using Flask
Next Part:
----------------
How to Deploy Python Flask Application on AWS EC2
• How to Deploy Python Flask Application on ...
Installation
------------------
python --version
python -m pip install --upgrade pip
pip install -r https://raw.githubusercontent.com/sno... -t .
pip install snowflake-connector-python==2.6.2 -t .
pip install pandas -t .
pip install "snowflake-connector-python[pandas]" -t .
pip install flask -t .
Code:
----------
import pandas as pd
import snowflake.connector as sf
import json
from flask import Flask,request
app=Flask(__name__)
user=""
password=""
account=""
database=""
warehouse=""
schema=""
role=""
conn=sf.connect(user=user,password=password,account=account)
statement_1='use warehouse '+warehouse
statement2='alter warehouse '+warehouse+" resume"
statement3="use database "+database
statement4="use role "+role
def run_query(conn, query):
print("Executing the {} query".format(query))
cursor = conn.cursor()
try:
cursor.execute(query)
except Exception as e:
print(e)
cursor.close()
def run_query1(conn, query):
cursor = conn.cursor()
cursor.execute(query)
records=str(cursor.fetchone()[0])
cursor.close()
return records
@app.route('/')
def hello_world():
return "Hello World , Welcome to Snowflake API"
@app.route('/aggregator',methods=['GET','POST'])
def stats_collector():
query_to_be_executed=request.args.get("query")
extracted_data=run_query1(conn, query_to_be_executed)
print(extracted_data)
return extracted_data
@app.route('/data_fetcher',methods=['GET','POST'])
def data_extractor():
query_to_be_executed = request.args.get("query")
data_from_table = pd.read_sql(query_to_be_executed, conn)
return {"data": json.loads(data_from_table.to_json(orient='records'))}
if __name__=='__main__':
run_query(conn, statement_1)
run_query(conn, statement2)
run_query(conn, statement3)
run_query(conn, statement4)
app.run()
Check this playlist for more AWS Projects or POC in Big Data domain:
• Demystifying Data Engineering with Cloud C...
In questa pagina del sito puoi guardare il video online Expose Snowflake Data by creating Python API della durata di ore minuti seconda in buona qualità , che l'utente ha caricato Knowledge Amplifier 04 dicembre 2021, condividi il link con amici e conoscenti, su youtube questo video è già stato visto 4,801 volte e gli è piaciuto 59 spettatori. Buona visione!
