Estoy programando una lambda para que se conecte a una base de datos de RedShift, ejecute una query y guarde el resultado de esta en un dataframe de pandas. He probado varias alternativas y no soy capaz. Estoy utilizando la librería de python psycopg2 así que una vez creo la conexión, procedo a ejecutar la query y cargarla como df:
conn = psycopg2.connect(
dbname=REDSHIFT_DBNAME,
host=REDSHIFT_HOST,
port=REDSHIFT_PORT,
user=REDSHIFT_USER,
password=REDSHIFT_PASSWORD,
c = conn.cursor
query = pd.read_sql_query ('''
SELECT a, b
FROM 'table'
GROUP BY B
''', conn)
df = pd.DataFrame(query, columns = ['a', 'b']
Me da error al leer la query:
{ "errorMessage": "Syntax error in module 'lambda_function': invalid syntax (lambda_function.py, line 19)", "errorType": "Runtime.UserCodeSyntaxError", "stackTrace": [ " File "/var/task/lambda_function.py" Line 19\n query = pd.read_sql_query ('''\n" ] }
Probando el código editado como sugiere el usuario abulafia:
cur = conn.cursor() query = pd.read_sql_query ("SELECT a, b FROM 'table' LIMIT 5", conn) df = pd.DataFrame(query, columns =['a', 'b']
Sigue saliendo el siguiente error:
{ "errorMessage": "Syntax error in module 'lambda_function': invalid syntax (lambda_function.py, line 20)", "errorType": "Runtime.UserCodeSyntaxError", "stackTrace": [ " File "/var/task/lambda_function.py" Line 20\n query = pd.read_sql_query ("SELECT a, b FROM 'table' LIMIT 5", conn)\n" ] }
No se porque ponga lo que ponga me salen las "/n"
'table'
?