Apache 빔 : 여러 구독에서 읽기

Question

여러 구독을 수신하고 BigQuery에 쓰는 데이터 흐름을 만들고 싶습니다. Google의 documentation에 따라 여러 PCollection 개의 개체를 읽고 조합 할 수 있습니다.

그러나 PubsubIO.Read의 javadoc here을 보면 은 subscription 메서드에서만 허용됩니다. 따라서 여러 구독에서 읽으려면 subscription 메서드를 연결해야합니까?

Answer 1

PubSub의 Read을 여러 구독하고 각각 하나의 구독에서 읽은 다음 Flatten 개의 결과를 얻을 수 있습니다.

필요한 것을 원하십니까?