时间戳

首页 > 解决方案 > PubSub 返回 503 - 服务一直不可用

google-cloud-pubsub - PubSub 返回 503 - 服务一直不可用

问题描述

我用 Python 创建了一个小程序，用于从 Pub/Sub 订阅中读取消息。我正在使用 Python 3.7 和 google-cloud-pubsub 1.1.0。

我的代码很简单：

from google.cloud import pubsub_v1
from google.auth import jwt
import json

service_account_info = json.load(open("service-account-info.json"))
audience_sub = "https://pubsub.googleapis.com/google.pubsub.v1.Subscriber"

credentials_sub = jwt.Credentials.from_service_account_info(
    service_account_info, audience=audience_sub
)

subscriber_ring = pubsub_v1.SubscriberClient(credentials=credentials_sub)

def callback1(message):
    print("In callback!!")
    print(message.data)
    message.ack()

sub_path = "projects/my-project/subscriptions/my-sub"
future = subscriber_ring.subscribe(sub_path, callback=callback1)
future.result()

当代码到达“future.result()”时，它会永远挂在那里，并在 10 分钟后超时并出现错误

pubsub 503 无法连接到所有地址

我已经验证了：

但我不能让它工作。有任何想法吗？

编辑：我从异常中获得了更多信息：

om_grpc_error(exc), exc)
  File "<string>", line 3, in raise_from
google.api_core.exceptions.ServiceUnavailable: 503 failed to connect to all addresses

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/usr/local/anaconda3/envs/loadtest/lib/python3.7/site-packages/google/cloud/pubsub_v1/publisher/_batch/thread.py", line 219, in _commit
    response = self._client.api.publish(self._topic, self._messages)
  File "/usr/local/anaconda3/envs/loadtest/lib/python3.7/site-packages/google/cloud/pubsub_v1/gapic/publisher_client.py", line 498, in publish
    request, retry=retry, timeout=timeout, metadata=metadata
  File "/usr/local/anaconda3/envs/loadtest/lib/python3.7/site-packages/google/api_core/gapic_v1/method.py", line 143, in __call__
    return wrapped_func(*args, **kwargs)
  File "/usr/local/anaconda3/envs/loadtest/lib/python3.7/site-packages/google/api_core/retry.py", line 286, in retry_wrapped_func
    on_error=on_error,
  File "/usr/local/anaconda3/envs/loadtest/lib/python3.7/site-packages/google/api_core/retry.py", line 206, in retry_target
    last_exc,
  File "<string>", line 3, in raise_from
google.api_core.exceptions.RetryError: Deadline of 60.0s exceeded while calling functools.partial(<function _wrap_unary_errors.<locals>.error_remapped_callable at 0x7fa030891a70>, 


, metadata=[('x-goog-request-params', 'topic=projects/my-project/subscriptions/my-sub'), ('x-goog-api-client', 'gl-python/3.7.6 grpc/1.26.0 gax/1.16.0 gapic/1.2.0')]), last exception: 503 failed to connect to all addresses

标签： google-cloud-pubsubgoogle-cloud-python

解决方案

可能存在防火墙规则或某些网络配置不允许/丢弃与 *.googleapis.com（或特别是 pubsub.googleapis.com）的连接。您可以在另一个 Google 产品中看到这样的示例。

推荐阅读