google.gax.errors.GaxError : GaxError RPC failed by ... StatusCode.UNAVAILABLE

Question

우리는 분산 시스템 중 하나에서 이벤트가 발생하면 기존 주제에 간단하게 게시하려고합니다. 같은

코드는 같습니다 우리를 제외하고는 모든 잡아 다시 추적을 인쇄 할 경우

try: 
    dat = data.encode('utf-8') 
    topic.publish(dat) 
except: 
    <code to recover> 

, 우리가 얻을 :

google.gax.errors.GaxError: GaxError(RPC failed, caused by <_Rendezvous of RPC that terminated with (StatusCode.UNAVAILABLE, {"created":"@1478711654.067744009","description":"Secure read failed","file":"src/core/lib/security/transport/secure_endpoint.c","file_line":157,"grpc_status":14,"referenced_errors":[{"created":"@1478711654.067706801","description":"EOF","file":"src/core/lib/iomgr/tcp_posix.c","file_line":235}]})>

(아래 전체 오류)

보면 http://gcloud-python.readthedocs.io/en/latest/pubsub-topic.html#google.cloud.pubsub.topic.Topic.publish, 이건 GAX 오류가 아닌 것처럼 보입니다. 우리가 알아야 할 것이 있습니다. 그러나 을 수행 할 경우 오류를 catch하고 지수 백 오프를 사용하여 다시 시도하면 정상적으로 두 번째로 작동합니다.

나는 _gax_python에서 잠정적 인 오류를 말하는 반면, 관련이없는 것 같습니다. 우리가 여기서 잘못하고있는 것에 대한 어떤 생각?

전체 오류 :

458 Traceback (most recent call last): 
    459  File "/usr/lib/python3.5/threading.py", line 914, in _bootstrap_inner 
    460  self.run() 
    461  File "/usr/lib/python3.5/threading.py", line 862, in run 
    462  self._target(*self._args, **self._kwargs) 
    463  File "/home/pp/pp/pp/process/uploader.py", line 145, in upload_thread 
    464  topic.publish(byte_string) 
    465  File "/home/pp/.virtualenvs/cv/lib/python3.5/site-packages/google/cloud/pubsub/topic.py", line 257, in publish 
    466  message_ids = api.topic_publish(self.full_name, [message_data]) 
    467  File "/home/pp/.virtualenvs/cv/lib/python3.5/site-packages/google/cloud/pubsub/_gax.py", line 165, in topic_publish 
    468  options=options) 
    469  File "/home/pp/.virtualenvs/cv/lib/python3.5/site-packages/google/cloud/gapic/pubsub/v1/publisher_api.py", line 289, in publish 
    470  return self._publish(request, options) 
    471  File "/home/pp/.virtualenvs/cv/lib/python3.5/site-packages/google/gax/api_callable.py", line 481, in inner 
    472  return api_caller(api_call, this_settings, request) 
    473  File "/home/pp/.virtualenvs/cv/lib/python3.5/site-packages/google/gax/api_callable.py", line 158, in inner 
    474  return a_func(request, **kwargs) 
    475  File "/home/pp/.virtualenvs/cv/lib/python3.5/site-packages/google/gax/api_callable.py", line 434, in inner 
    476  errors.create_error('RPC failed', cause=exception)) 
    477  File "/home/pp/.virtualenvs/cv/lib/python3.5/site-packages/future/utils/__init__.py", line 419, in raise_with_traceback 
    478  raise exc.with_traceback(traceback) 
    479  File "/home/pp/.virtualenvs/cv/lib/python3.5/site-packages/google/gax/api_callable.py", line 430, in inner 
    480  return a_func(*args, **kwargs) 
    481  File "/home/pp/.virtualenvs/cv/lib/python3.5/site-packages/google/gax/api_callable.py", line 64, in inner 
    482  return a_func(*updated_args, **kwargs) 
    483  File "/home/pp/.virtualenvs/cv/lib/python3.5/site-packages/grpc/_channel.py", line 481, in __call__ 
    484  return _end_unary_response_blocking(state, False, deadline) 
    485  File "/home/pp/.virtualenvs/cv/lib/python3.5/site-packages/grpc/_channel.py", line 432, in _end_unary_response_blocking 
    486  raise _Rendezvous(state, None, None, deadline) 
    487 google.gax.errors.GaxError: GaxError(RPC failed, caused by <_Rendezvous of RPC that terminated with (StatusCode.UNAVAILABLE, {"created":"@1478711654.067744009","description":"Secure read failed","file":"src/core/lib/security/transport/secure_endpoint.c","file_line":157,"grpc_status":14,"referenced_errors":[{"created":"@1478711654.067706801","description":"EOF","file":"src/core/lib/iomgr/tcp_posix.c","file_line":235}]})> 

Answer 1

그것은 당신이 찾고있는 관련 토론처럼 보인다는 문제 2683, "Frequent gRPC StatusCode.UNAVAILABLE errors"입니다.

잘못된 것은 아니며 예외를 포착하는 것처럼 보이며 다시 시도하는 것이 가장 적절한 해결 방법입니다.

Answer 2

주제가 전역 변수 인 경우 오류가 생성되지 않습니다. 주제를 클래스 변수를 확인하고 한 번만 인스턴스화 - 한 번만이 줄을 호출이는 파이썬 2.7 작동처럼 또한

topic = pubsub.Client().topic(name) 

이 보인다 - 파이썬 3.6 재 시도가 약간의 통증 마취.

비활성화 gRPC 파이썬 3.6에 대한 트릭 않습니다 -이이 환경 변수를 설정하여 수행 할 수 있습니다

ENV GOOGLE_CLOUD_DISABLE_GRPC=true 

Answer 3

가 나는 "정말 예쁘 없습니다"해결 방법을 얻을 관리 할 수 ​​있습니다. deadline_exceeded 코드가 google.cloud.pubsub_v1.subscriber.policy.thread.Policy.on_exception에 복제 된 정책 사용 내가

subscriber = pubsub.SubscriberClient(policy_class=UnavailableHackPolicy) 
subscription_path = subscriber.subscription_path(project, subscription_name) 
subscriber.subscribe(subscription_path, callback=callback, flow_control=flow_control) 

문제와 같은 코드가 메시지 수신 기능에

from google.cloud.pubsub_v1.subscriber.policy.thread import Policy 
import grpc 

class UnavailableHackPolicy(Policy): 
    def on_exception(self, exception): 
     """ 
     There is issue on grpc channel that launch an UNAVAILABLE exception now and then. Until 
     that issue is fixed we need to protect our consumer thread from broke. 
     https://github.com/GoogleCloudPlatform/google-cloud-python/issues/2683 
     """ 
     unavailable = grpc.StatusCode.UNAVAILABLE 
     if getattr(exception, 'code', lambda: None)() in [unavailable]: 
      print("¡OrbitalHack! - {}".format(exception)) 
      return 
     return super(UnavailableHackPolicy, self).on_exception(exception) 

자원이 진정으로 사용할 수 없을 때 우리가 인식하지 될 것입니다. 그러나 GRPC 개발자 팀이이 문제를 해결할 수있는 동안 우리는이 해결 방법을 사용할 것입니다.