调用 gmail API messages.send() 时，带有 pubsub 触发器的云函数无限执行

Question

我们正在使用具有电子邮件自动化功能的 Atlassian 状态页面，这意味着每当收到主题为“DOWN”的电子邮件时，它都会在屏幕上显示警报，并在收到主题为“UP”的电子邮件时删除相同的警报。

我激活了 Gmail Pub/Sub (https://developers.google.com/gmail/ api/guides/push) 推送通知，它监视 gmail 收件箱中的更改，并在更改实际发生时向 pub/sub 主题发送推送通知。

然后我创建了一个由发布/订阅通知触发的云函数。此云功能应该：

1. 阅读最新的未读电子邮件
2. 如果此电子邮件是我们的第 3 方提供商发送的警报，请相应地向状态页面发送一封新电子邮件，主题为“向下”或“向上”。

这是代码：

def access_oauth2_json():
  ### Code
  return creds_dict


def create_message(subject):
  ### Code
  return {'raw': b64_string}


def send_message(service, message, user_id = 'me'):
  try:
    response = service.users().messages().send(userId=user_id, body=message).execute()
    return response
  except HttpError as error:
    logging.error('An error occurred:', error)



def update_status_page(arg1,arg2):

  ### Initialise creds

  try:
    service = build('gmail', 'v1', credentials=creds)
    request = {
      'labelIds': ['INBOX'],
      'topicName': 'pubsub_topic_id'
    }
    service.users().watch(userId='me', body = request).execute()

    last_message_info = service.users().messages().list(userId='me', labelIds=['UNREAD'], q = 'in:inbox is:unread', maxResults=1).execute().get('messages', [])

    last_message = service.users().messages().get(userId='me', id=last_message_info[0]['id']).execute()

    header = last_message['payload']['headers']
    sub = ""
    for x in header:
      if x['name'] == 'Subject':
        sub = x['value'] #subject
        logging.info(sub)

    if 'special_alert_string' in sub:
      message = create_message(subject = 'DOWN')
      response = send_message(service, message)
    elif 'other_special_alert_string' in sub:
      message = create_message(subject = 'UP')
      response = send_message(service, message)

  except HttpError as error:
    logging.info(f'An error occurred: {error}')

  return 200

发生的情况是：

1. 当函数由非第三方警报的电子邮件触发时，if/elif 块不会执行，而是执行云函数 2 或3 次（而不是 1 次，但这对我来说很好，所以不是真正的问题）

2 - 问题 - 当函数被触发时一封是第三部分警报的电子邮件，执行 if/elif 块（两者之一）并且该函数无限执行！它只会因为达到每个时间间隔的最大 API 请求数而停止。

我尝试过的操作：

1. 删除 watch() 行，但没有成功
2. 注释掉 service.users().messages().send() 行又回到了情况 1，所以我的猜测是该指令是触发向 pub/sub 主题推送通知并生成无限循环。这个问题也许可以用另一个 watch() labelId 来解决，但我还没弄清楚是哪一个。

我希望这很清楚，谢谢您的帮助！