DoFn의 HTTP 클라이언트

Question

DataFlow에서 실행되는 Apache Beam Pipeline에 대해 DoFn을 통해 POST를 요청하고 싶습니다.

이를 위해 PoolingHttpClientConnectionManager에 구성된 HttpClosableClient를 인스턴스화하는 클라이언트를 만들었습니다.

그러나 내가 처리하는 각 요소에 대해 클라이언트를 인스턴스화합니다.

내 모든 요소에서 사용되는 영구 클라이언트를 어떻게 설정할 수 있습니까?

그리고 내가 사용해야하는 병렬 및 고속 HTTP 요청을위한 다른 클래스가 있습니까?

Answer 1

클라이언트를 멤버 변수에 넣고 @Setup 메서드를 사용하여 클라이언트를 열고 @Teardown을 사용하여 클라이언트를 닫을 수 있습니다. Beam에있는 거의 모든 입출력의 구현은이 패턴을 사용합니다. JdbcIO을 참조하십시오.