如何在Python语言中使用AckID确认谷歌PubSub消息

from google.cloud import pubsub_v1

publisher = pubsub_v1.PublisherClient()

topic_name = 'projects/<project_id>/topics/<topic_name>'
subscription_name = 'projects/<project_id>/subscriptions/<subscription_name>'

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

subscriber = pubsub_v1.SubscriberClient()
subscription_path = subscriber.subscription_path('<project_id>', '<subscription_name>')

subscriber.subscribe(subscription_path, callback=callback)

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