【问题标题】:Sending a message to AWS SQS Queue with AWS Lambda Python API Times out使用 AWS Lambda Python API 向 AWS SQS 队列发送消息超时
【发布时间】:2017-04-27 18:28:57
【问题描述】:

我正在尝试使用其 Python API 在 AWS Lambda 中写入 SQS 消息,但我尝试的任何操作都会超时(我已经运行了一分钟但没有成功)。我为该角色配置了 SQS 完全访问权限。我可以看到函数日志到达正确的位置,但最后一行显示

Starting new HTTPS connection (1): eu-west-1.queue.amazonaws.com

在超时之前。我正在使用 AWS 控制台中的测试客户端对其进行测试。

处理程序代码是:

import boto3
import logging
import os

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

QUEUE_NAME = os.getenv("QUEUE_NAME")
SQS = boto3.client("sqs")

def getQueueURL():
    """Retrieve the URL for the configured queue name"""
    q = SQS.get_queue_url(QueueName=QUEUE_NAME).get('QueueUrl')
    logger.debug("Queue URL is %s", QUEUE_URL)
    return q

def record(event, context):
    """The lambda handler"""
    logger.debug("Recording with event %s", event)
    data = event.get('data')
    try:
        logger.debug("Recording %s", data)
        u = getQueueURL()
        logging.debug("Got queue URL %s", u)
        resp = SQS.send_message(QueueUrl=u, MessageBody=data)
        logger.debug("Send result: %s", resp)
    except Exception as e:
        raise Exception("Could not record link! %s" % e)

检索队列 URL 似乎总是超时。为什么会这样,我该如何防止这种情况发生,以便我可以写入队列?

【问题讨论】:

  • 您是否将 Lambda 函数放置在 VPC 中?
  • 究竟是什么工作? VPC 没有角色,所以我什至不确定你在说什么。
  • 我的意思是,我删除了对 lambda 函数的 VPC 分配。很抱歉造成混乱。

标签: python amazon-web-services aws-lambda aws-sdk


【解决方案1】:

我已将此功能分配给 VPC 和关联的子网,这阻止了它访问外部资源。删除它解决了我的问题。

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2021-03-21
    • 1970-01-01
    • 2022-01-25
    • 2019-10-09
    • 2018-12-23
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多