AWS Lambda 函数连接到 RDS 错误答案

【问题标题】：AWS Lambda function to connect to RDS errorAWS Lambda 函数连接到 RDS 错误
【发布时间】：2020-01-30 05:24:43
【问题描述】：

我无法通过他们提供的测试示例使用 Lambda 函数连接到 RDS

这是代码：

import sys
import logging
import rds_config
import pymysql
#rds settings
rds_host  = "connection_link"
name = rds_config.db_username
password = rds_config.db_password
db_name = rds_config.db_name


logger = logging.getLogger()
logger.setLevel(logging.INFO)

try:
    conn = pymysql.connect(rds_host, user=name, passwd=password, db=db_name, connect_timeout=5)
except:
    logger.error("ERROR: Unexpected error: Could not connect to MySql instance.")
    sys.exit()

logger.info("SUCCESS: Connection to RDS mysql instance succeeded")

def handler(event, context):
    """
    This function fetches content from mysql RDS instance
    """

    item_count = 0

    with conn.cursor() as cur:
        cur.execute("create table Employee3 ( EmpID  int NOT NULL, Name varchar(255) NOT NULL, PRIMARY KEY (EmpID))")  
        cur.execute('insert into Employee3 (EmpID, Name) values(1, "Joe")')
        cur.execute('insert into Employee3 (EmpID, Name) values(2, "Bob")')
        cur.execute('insert into Employee3 (EmpID, Name) values(3, "Mary")')
        conn.commit()
        cur.execute("select * from Employee3")

        for row in cur:
            item_count += 1
            logger.info(row)
            #print(row)

    return "Added %d items from RDS MySQL table" %(item_count)

这是我的部署包的结构

app/pymysql/...
app/app.py
app/rds_config.py
app/PyMySQL-0.7.11.dist-info/...

我已将 app 文件夹内的所有文件打包成一个 zip 文件。

这是get的错误

"errorMessage": "RequestId: 96fb4cd2-79c1-11e7-a2dc-f97407196dbb 进程在完成请求前退出"

我已经在 MYSQL Workbench 上检查了我的 RDS 连接，它工作正常

【问题讨论】：

“他们提供的测试示例”是什么意思？能给个链接吗？
他们在文档link@JohnRotenstein 中提供的python 示例
您有复制/粘贴错误或def handler(event, context): 函数没有内容。换句话说，def handler(event, context): 行之后的所有内容都需要添加一个选项卡。在 Python 代码中，空格是语法。在尝试处理 AWS Lambda 之前，您需要掌握所使用语言的基本语法。
代码编译正常。它给出了捕获错误“错误：意外错误：无法连接到 MySql 实例。” @MarkB
这不是会阻止代码编译的错误，而是会阻止代码按您期望的方式工作的错误。您需要修复缩进以匹配您链接到的示例。此外，为了实现连接，您的 Lambda 函数需要与 MySQL RDS 实例位于同一 VPC 中，并且 RDS 安全组需要对分配给您的 Lambda 函数的安全组开放。

标签： python amazon-web-services aws-lambda

【解决方案1】：

更新：

让我们假设您的实际 Python 代码实际上与您在上面发布的代码不同的是正确缩进。

由于某种原因，您的函数无法连接到您的数据库。您基本上没有向用户返回错误，而是将其告知sys.exit(1)，这就是 Lambda 说“进程在完成请求之前退出”的原因。

-- 原始答案--

这看起来不像 AWS lambda 处理程序。

您应该编写一个接受 lambda 事件和上下文作为参数的函数处理程序。

请通过AWS Lambda documentation了解更多信息。

【讨论】：

实际上他已经定义了处理函数。查找代码def handler(event, context):。但是，由于代码的缩进方式，处理函数似乎没有内容。
你是对的。我看到了顶级return 所以我认为他没有处理函数。然后，我意识到你不能在 Python 中拥有它。

【解决方案2】：

正如@MarkB 在 cmets 中提到的，对于连接，您需要在您的 Lambda 函数中设置 VPC、Subnets 和 Security Group，与您的 RDS 实例相同：

您还需要检查安全组中的入站和出站Protocol、Port 和Source，以确保它对您的 IP 和端口范围开放。

【讨论】：

【解决方案3】：

我刚刚遇到了同样的问题，原来是因为我没有在创建数据库时指定名称。 Easy Create 没有为您提供此选项，因此您必须使用 Standard Create，您可以在 Additional Configuration 下指定名称.此名称是您应该在rds_config.py 中为db_name 指定的名称。

或者，您可以在没有数据库名称的情况下使用您选择的工具进行连接，执行CREATE DATABASE xxx; 其中xxx 是数据库的名称，然后可以继续使用该数据库。

来源：https://serverfault.com/a/996423

这个也有关系：Why don't I have access to the database from aws lambda but have from a local computer with the same login data?

【讨论】：

【解决方案4】：

您的 zip 文件有问题。

我也使用相同的 lambda 函数。

请按照以下步骤操作。

1. your app.py and rds_config.py files are good.

2. Then download the pymysql https://pypi.python.org/pypi/PyMySQL

3. Extract it.

4. Copy the pymysql to somewhere. (Note: Dont add all contents inside the PyMySQL-0.7.11 folder, we just need pymysql only.)

5. Then create a zip file with app.py, rds_config.py and pymysql folder.

【讨论】：