从Google Dataflow流媒体作业保存为弹性搜索

Kas*_*ady 7 elasticsearch logstash google-cloud-dataflow

我通过Google Dataflow Streaming作业将数据保存到BigQuery.

我想将此数据插入弹性搜索中以便快速访问.

从数据流通过http调用logstach是一个好习惯吗?

Pab*_*blo 6

Apache Beam Java SDK具有用于读取/写入Elastic搜索的连接器.这应该优化IO以与Beam模型一致.