文档

关联已有的 CMQ Topic

该例子中,我们通过 serverless.yml 创建了一个名为 cmq_trigger 的 CMQ 触发器,并且关联了一个名为 test-topic 的 CMQ Topic,每次这个 Topic 收到消息后,函数都会被调用。详情可以参考 CMQ 触发器概述

复制代码
functions:
  hello_world:
    handler: index.main_handler
    runtime: Nodejs8.9
    events:
      - cmq:
          name: cmq_trigger
          parameters:
            name: test-topic
            enable: true

注: CMQ 触发器默认开启。

CMQ Topic 触发器的事件消息结构

在指定的 CMQ Topic 主题队列接受到消息时,会将类似以下的 JSON 格式事件数据发送给绑定的 SCF 函数。

复制代码
{
  "Records": [
    {
      "CMQ": {
        "type": "topic",
        "topicOwner":120xxxxx,
        "topicName": "testtopic",
        "subscriptionName":"xxxxxx",
        "publishTime": "1970-01-01T00:00:00.000Z",
        "msgId": "123345346",
        "requestId":"123345346",
        "msgBody": "Hello from CMQ!",
        "msgTag": ["tag1","tag2"]
      }
    }
  ]
}
Serverless Framework
交流 QQ群_qrcode
小助手微信号_qrcode