Skip to content

Instantly share code, notes, and snippets.

@devender-yadav
Created May 31, 2019 09:58
Show Gist options
  • Save devender-yadav/a1ba74b6e3f141a431a3373974185823 to your computer and use it in GitHub Desktop.
Save devender-yadav/a1ba74b6e3f141a431a3373974185823 to your computer and use it in GitHub Desktop.
Running AWS Athena SQL queries
import sys
!{sys.executable} -m pip install PyAthena
from pyathena import connect
import pandas as pd
conn = connect(s3_staging_dir='s3://dev-sample-data123/temp',
region_name='ap-south-1')
df = pd.read_sql("SELECT * FROM rank_table limit 10;", conn)
# skipping header line
df1 = df.iloc[1:]
# changing datatype of rank to int
df1['rank'] = df1['rank'].astype(int)
df1.plot()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment