保存到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模型。