Should this work? Nothing seems to happen when I try to run code using psycopg2.
I follow these instructions:
http://docs.aws.amazon.com/lambda/latest/dg/lambda-python-how-to-create-deployment-package.html
so on an Amazon Linux instance, I create a Python 2.7 virtualenv
Then I do "pip install --upgrade pip"
Then I do pip install psycopg2 - I have see now these files:
(venv27)[ec2-user@ip-172-30-0-194 applyreplyPythonTest]$ ls /home/ec2-user/venv27/lib64/python2.7/site-packages/psycopg2
errorcodes.py extensions.py extras.py __init__.py _ipaddress.py _json.py pool.py psycopg1.py _psycopg.so _range.pyc sql.pyc tz.py
errorcodes.pyc extensions.pyc extras.pyc __init__.pyc _ipaddress.pyc _json.pyc pool.pyc psycopg1.pyc _range.py sql.py tests tz.pyc
(venv27)[ec2-user@ip-172-30-0-194 applyreplyPythonTest]$
I copy psycopg2 to the root of my Lambda code directory, where I have a lambda_function.py
#!/usr/bin/python
from __future__ import print_function
import psycopg2
import sys
import pprint
import json
import urllib
import boto3
def getdata():
conn_string = "host='some address' dbname='DBNAME' user='XXXXXXX' password='XXXXXXX'"
# print the connection string we will use to connect
print("Connecting to database\n ->%s" % (conn_string))
# get a connection, if a connect cannot be made an exception will be raised here
print('floob')
conn = psycopg2.connect(conn_string)
print('conn.status', conn.status)
print('conn.server_version', conn.server_version)
# conn.cursor will return a cursor object, you can use this cursor to perform queries
cursor = conn.cursor()
# execute our Query
cursor.execute("SELECT * FROM cognitouser")
# retrieve the records from the database
results = []
for row in cursor.fetchall():
print(row)
#results.append(row)
# print out the records using pretty print
# note that the NAMES of the columns are not shown, instead just indexes.
# for most people this isn't very useful so we'll show you how to return
# columns as a dictionary (hash) in the next example.
#pprint.pprint(records)
def lambda_handler(event, context):
#print("Received event: " + json.dumps(event, indent=2))
getdata()
return json.dumps(event)
I then upload my function to AWS as a zipfile via S3.
It does run, however, there is no output on the Lambda Cloudwatch log after it prints "floob".
I have independently checked that the database server is accessible.
Can anyone suggest what I might be doing wrong?
thanks