CMQ 触发器（消息队列）

使用方式

在 f.yml 中配置函数和触发器。

service: midway-faas-examples
provider:
  name: tecent
functions:
  mqTrigger:
    handler: cmq.handler
    events:
      - cmq:
          topic: test-topic-queue
          enable: false
package:
  artifact: code.zip

在 f deploy 后，即可。

:::info 注意，在腾讯云下，midway faas 提供的默认消息队列格式为 JSON :::

开发支持

针对 CMQ（mq） 触发器，我们提供了传入的事件类型定义。

import { SCF } from '@midwayjs/faas';
export class CMQTriggerTest {
  @Func('cmq.handler')
  async handler(event: SCF.CMQEvent) {
      // TODO
  }
}

本地开发

使用 f invoke 命令进行触发。

f invoke -f [你的函数名]

本地测试

这里没有传 data，会默认通过 f.yml 获取触发器类型传入模拟数据。

// test
describe('/test/index.test.ts', () => {
  it('invoke', async () => {
    await invoke({
      functionName: 'mqTrigger',    
    });
  });
});