In [2]:
import psycopg2
import pandas as pd
In [3]:
statement = """SELECT job_id, count(*)
FROM twitter.tweet
where lower(text) like '%trump%'
group by job_id;"""
try:
connect_str = "dbname='twitter' user='dsa_ro_user' host='dbase.dsa.missouri.edu'password='readonly'"
# use our connection values to establish a connection
conn = psycopg2.connect(connect_str)
cursor = conn.cursor()
cursor.execute(statement)
column_names = [desc[0] for desc in cursor.description]
rows = cursor.fetchall()
except Exception as e:
print("Uh oh, can't connect. Invalid dbname, user or password?")
print(e)
In [ ]: