PublisherClient에서 Pubsub Emulator를 google-cloud-pubsub 버전 0.28

Question

에서 사용하는 방법 Google에서 Python 클라이언트를 PublisherClient 및 SubscriberClient로 재구성 한 google-cloud-pubsub 버전 0.28로 업데이트합니다. 로컬 호스트의 Pubsub 에뮬레이터에 연결하려고했지만 환경 변수를 설정했지만 클라우드 pubsub의 모든 항목을 나열 할 수있는 클라우드 pubsub 서비스에는 계속 연결되지만 에뮬레이터의 항목은 목록에 포함 할 수 없습니다. 여기

제가

연결하는 데 사용되는 코드

from google.cloud import pubsub 
import os 
os.environ['PUBSUB_EMULATOR_HOST'] = 'localhost:8085' 
os.environ['GOOGLE_CLOUD_PROJECT'] = 'my-project' 
publisher = pubsub.PublisherClient() 
topic = 'projects/my-project/topics/abc' 
publisher.get_topic(topic) 

를 에뮬레이터이며 여기 예외 : 문제는 고정 된 스럽다

Traceback (most recent call last): 
    File "<input>", line 5, in <module> 
    File "/Users/sx5640/Envs/uie/lib/python2.7/site-packages/google/cloud/pubsub_v1/_gapic.py", line 42, in <lambda> 
    fx = lambda self, *a, **kw: wrapped_fx(self.api, *a, **kw) 
    File "/Users/sx5640/Envs/uie/lib/python2.7/site-packages/google/cloud/gapic/pubsub/v1/publisher_client.py", line 341, in get_topic 
    return self._get_topic(request, options) 
    File "/Users/sx5640/Envs/uie/lib/python2.7/site-packages/google/gax/api_callable.py", line 452, in inner 
    return api_caller(api_call, this_settings, request) 
    File "/Users/sx5640/Envs/uie/lib/python2.7/site-packages/google/gax/api_callable.py", line 438, in base_caller 
    return api_call(*args) 
    File "/Users/sx5640/Envs/uie/lib/python2.7/site-packages/google/gax/api_callable.py", line 376, in inner 
    return a_func(*args, **kwargs) 
    File "/Users/sx5640/Envs/uie/lib/python2.7/site-packages/google/gax/retry.py", line 127, in inner 
    ' classified as transient', exception) 
RetryError: RetryError(Exception occurred in retry method that was not classified as transient, caused by <_Rendezvous of RPC that terminated with (StatusCode.NOT_FOUND, Resource not found (resource=abc).)>) 

Answer 1

0.29