概览

编辑

概览编辑

这是 Elasticsearch 的官方 Rust 客户端。完整文档托管在docs.rs上，本页面*仅*提供概述。

更多资源

特性编辑

所有 Elasticsearch REST API 端点的 Fluent 构建器
持久保持活动连接
支持使用系统或自定义证书的 TLS
支持带身份验证的代理
使用 Tokio 进行异步支持

Elasticsearch 版本兼容性编辑

Elasticsearch Rust 客户端是向前兼容的；这意味着客户端支持与更高次要版本的 Elasticsearch 通信。Elasticsearch 语言客户端也向后兼容受支持的较低次要版本的 Elasticsearch。

创建客户端编辑

要创建客户端以对运行在\https://127.0.0.1:9200上的 Elasticsearch 进行 API 调用

let client = Elasticsearch::default();

或者，您可以创建一个客户端，以便对在特定url::Url上运行的 Elasticsearch 进行 API 调用

let transport = Transport::single_node("https://example.com")?;
let client = Elasticsearch::new(transport);

如果您针对Elastic Cloud中的 Elasticsearch 部署运行，则可以使用Cloud ID和从 Cloud Web 控制台检索到的凭据创建客户端

let cloud_id = "<cloud id from cloud web console>";
let credentials = Credentials::Basic("<username>".into(), "<password>".into());
let transport = Transport::cloud(cloud_id, credentials)?;
let client = Elasticsearch::new(transport);

进行 API 调用编辑

以下是对tweets/_search进行 API 调用，并使用 JSON 正文{"query":{"match":{"message":"Elasticsearch"}}}

let response = client
    .search(SearchParts::Index(&["tweets"]))
    .from(0)
    .size(10)
    .body(json!({
        "query": {
            "match": {
                "message": "Elasticsearch rust"
            }
        }
    }))
    .send()
    .await?;

let response_body = response.json::<Value>().await?;
let took = response_body["took"].as_i64().unwrap();
for hit in response_body["hits"]["hits"].as_array().unwrap() {
    // print the source document
    println!("{:?}", hit["_source"]);
}

安装 »