- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我正在使用 Gmail API,并尝试使用 Python 3.9 设置推送通知。当我尝试在 Gmail 收件箱上调用 watch() 时,出现错误,即使我已遵循针对类似问题给出的所有建议。错误如下:
“向 Cloud PubSub 项目/[project-id]/topics/[topic-id] 发送测试消息时出错:用户无权执行此操作。”
到目前为止,我已经完成了以下工作:
就代码而言,我只是添加到 Google 提供的 Python Quickstart 文件 ( https://developers.google.com/gmail/api/quickstart/python ) 中。这是我添加的内容:
from __future__ import print_function
import os.path
from googleapiclient.discovery import build
from google_auth_oauthlib.flow import InstalledAppFlow
from google.auth.transport.requests import Request
from google.oauth2.credentials import Credentials
# If modifying these scopes, delete the file token.json.
SCOPES = ['https://www.googleapis.com/auth/gmail.readonly']
def main():
"""Shows basic usage of the Gmail API.
Lists the user's Gmail labels.
"""
creds = None
# The file token.json stores the user's access and refresh tokens, and is
# created automatically when the authorization flow completes for the first
# time.
if os.path.exists('token.json'):
creds = Credentials.from_authorized_user_file('token.json', SCOPES)
# If there are no (valid) credentials available, let the user log in.
if not creds or not creds.valid:
if creds and creds.expired and creds.refresh_token:
creds.refresh(Request())
else:
flow = InstalledAppFlow.from_client_secrets_file(
'credentials.json', SCOPES)
creds = flow.run_local_server(port=0)
# Save the credentials for the next run
with open('token.json', 'w') as token:
token.write(creds.to_json())
#NEW CODE I ADDED FOR watch()
service = build('gmail', 'v1', credentials=creds)
request = {
'labelIds': ['INBOX'],
'topicName': 'projects/[project-id]/topics/[topic-id]'
}
service.users().watch(userId='me', body=request).execute()
if __name__ == '__main__':
main()
编辑:
编辑2:我使用上面的凭据添加了完整文件。
最佳答案
我已经测试了您的代码,并且遇到了同样的问题,但这是因为我故意跳过了一些步骤来弄清楚某些阶段会发生什么。
当我没有添加服务帐户时,我遇到了您的具体问题 <a href="https://stackoverflow.com/cdn-cgi/l/email-protection" class="__cf_email__" data-cfemail="77101a161e1b5a16071e5a0702041f37040e0403121a5910041205011e1412161414180219035914181a" rel="noreferrer noopener nofollow">[email protected]</a>
作为相关主题的发布者。
所以问题是,您正在尝试使用服务帐户来验证 @gmail.com 帐户的 Gmail API 的 API 调用,我猜测遵循 this example .
唯一可行的方法是,如果您使用的帐户是 GSuite 帐户并且您正在使用域范围委派。 This doc (对于 Admin SDK,但其工作方式是相同的)解释了其工作原理。它不适用于您,但为了完整起见,我添加了此内容。
服务帐户不能用于验证 @gmail.com 帐户的请求。
它们可以用于验证自己的 GSuite 相关 API,例如 GDrive、GDocs 等,但它们基本上用于验证自己的帐户,而不是 @gmail.com 帐户。我不会详细介绍这一点,因为这并不完全相关,而且这是一个有点奇怪的兔子洞,即使爱丽丝也无法摆脱。
要将 Gmail API 与您的 @gmail.com 帐户结合使用,您需要按照快速入门 you linked 中的说明创建 creds 对象。所以请求得到 authenticated using the credentials for your @gmail.com account 。您只需执行一次此操作,并将生成的 JSON 凭证文件保存在某处,以便您可以重复使用它。它将一直有效,直到您撤销它为止。
请注意the docs还声明您需要使用标准 Gmail API 身份验证。
下面的部分创建 JSON 文件,您可以使用该文件通过登录时使用的 @gmail.com 帐户对 Gmail API 的请求进行身份验证。
# Save the credentials for the next run
with open('token.json', 'w') as token:
token.write(creds.to_json())
您可以使用这部分将凭据加载到 creds 对象中,然后只需使用您已有的代码就可以了...
if os.path.exists('token.json'):
creds = Credentials.from_authorized_user_file('token.json', SCOPES)
我不能 100% 确定您是否需要授予 GCloud 项目本身的权限,但您可以通过完成快速入门的其余部分来测试 Gmail 信用对象是否有效,并查看是否可以获得该项目的标签。 @gmail.com 帐户。如果此方法有效,但您仍然收到 403 错误,请尝试向 @gmail.com 帐户授予您向服务帐户授予的 Pub/Sub IAM 权限。
关于python - GmailAPI : "Error sending test message to Cloud PubSub projects/[project-id]/topics/[topic-id] : User not authorized to perform this action."?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/68091042/
对新版本 com.google.cloud.pubsub.spi.v1.Publisher.publish(pubsubMessage).get() 的调用永远挂起。我不确定问题是什么。 代码片段:
根据这里:https://cloud.google.com/pubsub/docs/reference/rest/v1/PubsubMessage 当发布者向队列发送消息时,不应填充时间戳字段。所以这
Google PubSub 是否适合小批量(10 条消息/秒)但任务关键型消息传递,保证在任何固定时间段内及时传递每条消息? 或者,它是否更适合高吞吐量,其中个别消息可能偶尔会丢失或无限期延迟? 编辑
我们创建了一个 pull使用 GCP Web GUI 的默认确认截止时间为 10 秒的 PubSub 订阅。原来是我们太乐观了,我们的服务处理一批拉取的消息需要10多秒的时间。该服务不会抛出异常,它实
批处理 pubsub 请求的 NODEJS 示例代码如下所示: // Imports the Google Cloud client library const PubSub = require(`@
在 Google PubSub 中,可以异步调用来自客户端的发布调用。因此,我认为可以同时触发多个发布请求并将其发送到服务器,尤其是在批处理阈值太低的情况下。 如果这是真的,pubsub 客户端如何控
根据堆栈驱动程序图表,我们开始注意到某个主题/订阅的“未确认消息”数量不时增加。 症状 我不知道我们可以信任多少堆栈驱动程序图表,但我已经检查过: 拉取操作数与发布操作数一样多 问题发生时ack操作计
我有一个将数据写入 Google Cloud pubsub 的应用程序,根据 pubsub 的文档,由于重试机制导致的重复是偶尔会发生的事情。还有乱序消息的问题,这在 pubsub 中也不能保证。 另
我有一个包含多个拉取订阅的 pubsub 主题。我想要某种机制,我可以在其中发布带有“优先级”标签的消息,使消息尽可能地跳到队列的前面。 我不需要任何有保证的排序语义,只需要“尽力而为”的优先级机制。
我在我们的平台中集成了 GMB API,并与 PubSub 合作以获取实时评论通知。 为此,我已经完成了以下步骤: Created topic在谷歌 PubSub 云上。 创建了它的 subscrip
试图找出在本地测试 PubSub 推送端点的最佳方法。我们尝试过使用 ngrok.io,但您必须拥有域才能加入白名单(这样做的工具也已损坏……导致无限重定向循环)。我们还尝试在本地模拟 PubSub。
我们希望通过带有 pubsub 触发器 ( https://firebase.google.com/docs/functions/pubsub-events ) 的 firebase 云函数接收有关某
关闭。这个问题是opinion-based .它目前不接受答案。 想改善这个问题吗?更新问题,以便可以通过 editing this post 用事实和引文回答问题. 2年前关闭。 Improve t
我有一个向 PubSub 主题发布消息的简单服务,偶尔会收到“已超过截止日期”错误消息: GaxError(RPC failed, caused by ) Python代码: from google.
我的应用程序发布少量消息(最多每几秒 1 条)。它不订阅。 首次使用时,PubSub 会创建 60 个永久保持事件状态的线程,如下所示: "grpc-default-worker-ELG-1-1 Id
我想检查运行代码是否有权在特定项目中执行“pubsub.topics.list”。这段代码: try (TopicAdminClient admin = getTopicAdmin()) {
我正在开发微博 spring mvc hibernate 应用程序。我需要实现像推特这样的发布订阅功能。 我正在使用 RabbitMQ 通过 Spring AMQP 抽象进行消息传递。 我在网络上到处
我对 Airflow 很陌生,并尝试使用 apache Airflow 与 google pubsub 的集成,我猜它是添加到“Airflow-300”JIRA 下的。如果我在这里阅读不正确,请纠正我
我正在学习 https://www.woolha.com/tutorials/node-js-google-cloud-pub-sub-basic-examples 上的教程并且有一些困难.. 我在
我在我的 .net 核心微服务中使用 DAPR 和 Docker。我在 docker-compose.yml 中进行了以下配置以运行代理和 dapr pubsub 配置。 PUBSUB.yml api
我是一名优秀的程序员,十分优秀!