将 psycopg2 与 Lambda 结合使用以更新 Redshift （Python）

问：

我正在尝试使用 python 从 Lambda 函数更新 Redshift。为此，我正在尝试组合 2 个代码片段。当我单独运行它们时，这两个片段都可以正常工作。

1. 从 PyDev for Eclipse 更新 Redshift

   import psycopg2
   
   conn_string = "dbname='name' port='0000' user='name' password='pwd' host='url'"
   conn = psycopg2.connect(conn_string)
   
   cursor = conn.cursor()
   
   cursor.execute("UPDATE table SET attribute='new'")
   conn.commit()
   cursor.close()
   

2. 接收上传到 S3 存储桶的内容（Lambda 上提供的预构建模板）

   from __future__ import print_function
   
   import json
   import urllib
   import boto3
   
   print('Loading function')
   
   s3 = boto3.client('s3')
   
   
   def lambda_handler(event, context):
       #print("Received event: " + json.dumps(event, indent=2))
   
       # Get the object from the event and show its content type
       bucket = event['Records'][0]['s3']['bucket']['name']
       key = urllib.unquote_plus(event['Records'][0]['s3']['object']['key']).decode('utf8')
   
       try:
           response = s3.get_object(Bucket=bucket, Key=key)
           print("CONTENT TYPE: " + response['ContentType'])
           return response['ContentType']
   
       except Exception as e:
           print(e)
           print('Error getting object {} from bucket {}. Make sure they exist and your bucket is in the same region as this function.'.format(key, bucket))
           raise e
   

由于这两个部分都有效，我尝试将它们组合在一起，以便在将文件上传到 s3 时更新 Redshift：

from __future__ import print_function

import json
import urllib
import boto3
import psycopg2

print('Loading function')

s3 = boto3.client('s3')


def lambda_handler(event, context):
    #print("Received event: " + json.dumps(event, indent=2))

    # Get the object from the event and show its content type
    bucket = event['Records'][0]['s3']['bucket']['name']
    key = urllib.unquote_plus(event['Records'][0]['s3']['object']['key']).decode('utf8')

    conn_string = "dbname='name' port='0000' user='name' password='pwd' host='url'"

    conn = psycopg2.connect(conn_string)

    cursor = conn.cursor()

    cursor.execute("UPDATE table SET attribute='new'")
    conn.commit()
    cursor.close()

    try:
        response = s3.get_object(Bucket=bucket, Key=key)
        print("CONTENT TYPE: " + response['Body'].read())
        return response['Body'].read()
    except Exception as e:
        print(e)
        print('Error getting object {} from bucket {}. Make sure they exist and your bucket is in the same region as this function.'.format(key, bucket))
        raise e

由于我使用的是外部库，因此需要创建一个部署包。我创建了一个新文件夹 （lambda_function1） 并将我的.py文件 （lambda_function1.py） 移动到该文件夹。我运行以下命令在该文件夹中安装 psycopg2：

pip install psycopg2 -t \lambda_function1

我收到以下反馈：

Collecting psycopg2
  Using cached psycopg2-2.6.1-cp34-none-win_amd64.whl
Installing collected packages: psycopg2
Successfully installed psycopg2-2.6.1 

然后，我压缩了目录的内容。并将该 zip 上传到我的 lambda 函数。当我将文档上传到函数监控的存储桶时，我在 cloudwatch 日志中收到以下错误：

Unable to import module 'lambda_function1': No module named _psycopg 

当我查看库时，唯一名为“_psycopg”的是“_psycopg.pyd”。

是什么导致了这个问题？当我使用 Python 3.4 时，Lambda 使用 Python 2.7 有关系吗？我在 Windows 机器上压缩文件内容有关系吗？有没有人能够从 lambda 成功连接到 Redshift？