保存到Google Dataflow流式作業的彈性搜索

Question

我通過Google Dataflow Streaming作業將數據保存到BigQuery。

我想插入這個數據到快速訪問彈性搜索。

從數據流通過http調用logstach是一個好習慣嗎？

Answer 1

Apache Beam Java SDK有一個connector to read from/write to Elastic search。這應該優化IO以符合Beam模型。