本地Docker环境下Pub/Sub emulator如何触发Functions-framework云函数

• 函数逻辑位置错误：你把Pub/Sub订阅监听逻辑写在了函数入口helloPubSub内部，这个函数只有被触发时才会执行，因此监听代码从始至终没有运行，自然收不到消息。
• Functions Framework触发逻辑不匹配：你用--signature-type=event参数启动框架，该模式下的函数需要外部事件推送才能触发，本身不会主动去Pub/Sub拉取消息。
• 订阅类型不匹配：你在Pub/Sub模拟器中创建的published-events-pull是拉取类型订阅，Pub/Sub不会主动把消息推送给函数端点。

提供两种可选方案，第一种更贴近生产环境行为，推荐优先使用。

方案1：改用推送订阅+标准事件触发（推荐） #

完全模拟云上Pub/Sub触发云函数的逻辑，无需大幅改动原有配置。

1. 修改docker-compose中Pub/Sub服务的环境变量，将订阅改为推送类型，推送地址指向functions服务的内部端点：

pubsub:
  image: messagebird/gcloud-pubsub-emulator
  environment:
    PUBSUB_PROJECT1: 'pubsubproject,published-events:published-events-push:http://functions:8888'
  ports:
    - "8681:8681"

2. 清理Cloud Functions代码中的冗余订阅逻辑，仅保留业务处理代码：

import { PubSub } from '@google-cloud/pubsub'

exports.helloPubSub = (data, context) => {   
    console.log("FROM CLOUD FUNCTION")
    const messageData = JSON.parse(Buffer.from(data.data, 'base64').toString())
    console.log('Received data:')
    console.log(messageData)
};

3. 原有package.json启动脚本无需修改，保持signature-type=event配置即可。

方案2：改为独立拉取订阅进程（适合本地快速调试） #

如果不想改动订阅类型，可直接让函数服务作为常驻进程主动拉取消息，无需使用Functions Framework的事件模式。

1. 新增入口文件src/pull-worker.ts，将订阅逻辑移到全局入口位置：

import { PubSub } from '@google-cloud/pubsub'

const pubSub = new PubSub()
const subscription = pubSub.subscription("published-events-pull")

const messageHandler = async message => {
    const data = JSON.parse(Buffer.from(message.data, 'base64').toString())
    console.log('Received data:')
    console.log(data)
    // 此处调用你的业务处理逻辑即可
    message.ack()
}

subscription.on('message', messageHandler)
console.log('Pub/Sub拉取进程已启动，正在监听消息...')

2. 修改package.json启动脚本，直接运行拉取进程，无需启动functions-framework：

"scripts": {
  "dev": "yarn run build:dev:init && yarn run build:dev | node dist/pull-worker.js",
  "build:dev:init": "yarn run tsc ",
  "build:dev": "yarn run tsc -w "
}

修改完成后重启所有docker-compose服务，调用你的应用接口发布消息，即可在functions容器日志中看到消息打印。

内容的提问来源于stack exchange，提问作者mmm