파이프 라인에 신호가 원활하게 전달되도록

Question

빔 2.3.0으로 작업 중입니다. 필자는 이틀 동안 DirectRunner로 정상적으로 pipline을 종료하는 방법을 조사했습니다. blockOnRun을 false로 설정하고 cancel을 호출하면 파이프 라인이 종료되고 데이터가 손실 될 수 있습니다. 파이프 라인을 먼저 배수하면 데이터 흐름 러너처럼 파이프를 배수 할 수 있는지 궁금합니다.

Answer 1

이 기능은 아직 빔 모델 수준에 존재하지 않습니다. 이와 비슷한 것을 구현하는 유일한 주자는 Dataflow의 Drain 기능입니다. 이것을 일반적인 Beam API로 만드는 것에 대해 논의 된 proposal이 있습니다.