如何使用python HTTP服务器拉取GCP发布/订阅消息？

import http.server
import socketserver
import json

class RequestHandler(http.server.BaseHTTPRequestHandler):
    def do_POST(self):
        content_length = int(self.headers['Content-Length'])
        post_data = self.rfile.read(content_length)
        data = json.loads(post_data.decode('utf-8'))
        
        # 在这里处理接收到的消息数据
        # 可以根据需要进行相应的业务逻辑处理
        
        self.send_response(200)
        self.end_headers()

PORT = 8000  # 指定服务器监听的端口号
Handler = RequestHandler

with socketserver.TCPServer(("", PORT), Handler) as httpd:
    print("Server started on port", PORT)
    httpd.serve_forever()

from google.cloud import pubsub_v1

def do_POST(self):
    # ...

    # 处理接收到的消息数据
    # ...

    # 使用Google Cloud Pub/Sub客户端库订阅和接收消息
    subscriber = pubsub_v1.SubscriberClient()
    subscription_path = subscriber.subscription_path(project_id, subscription_name)

    def callback(message):
        # 处理接收到的消息
        print(f"Received message: {message.data}")
        message.ack()

    subscriber.subscribe(subscription_path, callback=callback)