let builder = AsyncClientBuilder::new()
.static_node("http://192.168.1.127:9200")
.params_fluent(move |p| p
.url_param("pretty", true)
.header(AUTHORIZATION, auth.clone()));
let client = builder.build()?;
[2019-09-23T00:29:09Z ERROR elastic::http::sender::asynchronous] Elasticsearch Response: correlation_id: 'c325f648-fe9a-4cbb-b9cd-23c2a30b54b8', error: 'Client(ClientError { inner: Error(Request, State { next_error: Some(Error(Hyper(Error(Connect, Os { code: 10061, kind: ConnectionRefused, message: "由于目标计算机积极拒绝,无法连接。" })), "http://localhost:9200/bulk_idx/_bulk")), backtrace: Some(stack backtrace: