SQS Lambda 无服务器:不会使用 Sqs 消息

Question

我使用Serverless framework部署了一个Python Post API lambda。

代码详情如下：

app.py

from flask import Flask, jsonify, request
app = Flask(__name__)
@app.route('/process', methods=['POST'])
def process():
    content = request.json
    print content
    return jsonify(content)
if __name__ == "__main__":
    app.run()

serverless.yml

service: my-service
plugins:
  - serverless-python-requirements
  - serverless-wsgi
custom:
  wsgi:
    app: app.app
    packRequirements: false
  pythonRequirements:
    dockerizePip: false
package:
  exclude:
    - node_modules/**
    - venv/**
provider:
  name: aws
  runtime: python2.7
  stage: dev
  region: eu-west-1
functions:
  app:
    handler: wsgi.handler
    events:
      - http: ANY /
      - http: 'ANY {proxy+}'

我配置 SQS 以触发 lambda。我发送了一条 SQS 消息，lambda 被触发（我从 CloudWatch 检查了它），但 SQS 消息卡在飞行中。似乎 SQS 不能被 lambda 消耗。

任何建议都值得赞赏

****更新*****

仔细检查CloudWatch后，我发现了一些异常

u'headers': KeyError
Traceback (most recent call last):
File "/var/task/wsgi.py", line 100, in handler
return serverless_wsgi.handle_request(wsgi_app, event, context)
File "/var/task/serverless_wsgi.py", line 73, in handle_request
headers = Headers(event[u"headers"])
KeyError: u'headers'

Answer 1

查看您的日志，似乎 Flask 的 WSGI 期待您收到的有效负载中有一个headers节点，如果您的事件是 HTTP 事件，该节点将在那里。当您直接连接两个 AWS 服务时，情况并非如此。每个服务的event对象将不同。由于您不处理HTTP请求，因此我建议您从此lambda中删除Flask。

然后，您的代码将如下所示：

import json
def process(event,context):
    content = request.json
    print(event)
    return json.dumps(content,ensure_ascii=False)

service: my-service
plugins:
  - serverless-python-requirements
package:
  exclude:
    - node_modules/**
    - venv/**
provider:
  name: aws
  runtime: python2.7
  stage: dev
  region: eu-west-1
functions:
  app:
    handler: app.process
    events:
      - sqs:
          arn: arn:partition:service:region:account-id:resource-id
          batchSize: 1

您的 SQS 队列 ARN 显示在 AWS 控制台上的队列详细信息中。

以下是免费阅读：

SLS 和 SQS 队列