如何让Functions-framework（模拟器）订阅到Pub/Sub模拟器？

1. 在本地计算机上启动Pub/Sub模拟器，方法如下：

   $ gcloud components install pubsub-emulator
   $ gcloud beta emulators pubsub start --project=<project-id>
   

2. 在Functions-framework的入口函数中，创建Pub/Sub客户端并订阅主题，代码示例如下：

   import os
   from google.cloud import pubsub_v1
   from google.cloud.pubsub_v1.subscriber.message import Message
   
   def pubsub_emulator_demo(request):
       topic_name = 'my-topic'
       subscription_name = 'my-subscription'
   
       # 设置模拟器主机和端口
       os.environ['PUBSUB_EMULATOR_HOST'] = 'localhost:8085'
   
       # 创建Pub/Sub客户端
       subscriber = pubsub_v1.SubscriberClient()
   
       # 订阅主题
       subscription_path = subscriber.subscription_path('<project-id>', subscription_name)
       def callback(message: Message) -> None:
           # 处理接收到的消息
           print(f"Received message: {message.data}")
           message.ack()
   
       # 开始订阅
       flow_control = pubsub_v1.types.FlowControl(max_messages=1)
       subscriber.subscribe(subscription_path, callback=callback, flow_control=flow_control)
   
       return 'ok'
   

3. 运行Functions-framework的本地开发服务器，示例代码如下：

   from functions_framework import create_app
   
   app = create_app()
   
   if __name__ == '__main__':
       app.run(
           host='localhost',
           port=8080,
           debug=True
       )
   

4. 向主题发送消息，并观察Functions-framework的日志输出，示例代码如下：

   import os
   from google.cloud import pubsub_v1
   
   # 设置模拟器主机和端口
   os.environ['PUBSUB_EMULATOR_HOST'] = 'localhost:8085'
   
   # 创建Pub/Sub客户端
   publisher = pubsub_v1.PublisherClient()
   
   # 发送消息到主题
   topic_name = 'my-topic'
   data = b'hello world'
   future = publisher.publish(topic_name, data)
   print(f"Published message on {future.result()} : {data}")
   

注：示例代码中使用的是Python 3.9版本。