데이터 흐름 파이프 라인 및 pubsub 에뮬레이터

Question

내 개발 환경을 설정하려고합니다. 프로덕션 환경에서 Google 클라우드 pubsub를 사용하는 대신 개발 및 테스트를 위해 pubsub 에뮬레이터를 사용했습니다. 이를 위해 나는 다음과 같은 환경 변수 설정 :

export PUBSUB_EMULATOR_HOST=localhost:8586 

이것은 파이썬 구글 pubsub 라이브러리 위해 일을하지만 구글의 흐름에 대한 자바 아파치 빔을 사용하여 전환 할 때, 파이프 라인은 여전히 ​​생산 구글 pubsub를 가리 킵니다. 파이프 라인에서 로컬 pubsub 에뮬레이터를 읽도록 설정해야하는 설정, 환경 변수 또는 메서드가 파이프 라인에 있습니까?

Answer 1

PubsubOptions 인터페이스에서 솔루션을 찾은 다음 PipelineOptions 구현을 확장했습니다. 그런 다음 setPubsubRootUrl()을 사용하여 에뮬레이터의 localhost : port로 설정합니다.