集群节点数据

您可以检索 Weaviate 集群中各个节点的信息。查询可以针对整个集群，也可以针对特定的集合。

参数

名称	位置	类型	描述
输出	正文	字符串	指定输出中包含的信息量。选项：minimal（默认）和 verbose（包含分片信息）。

返回的数据：

nodes 端点返回一个节点数组。这些节点具有以下字段

• name：节点名称。
• status：节点状态（以下之一：HEALTHY、UNHEALTHY、UNAVAILABLE、INDEXING）。
• version：节点上运行的 Weaviate 版本。
• gitHash：节点上运行的 Weaviate 最新提交的简短 git 哈希值。
• stats：节点的统计信息。
  • shardCount：节点上的分片总数。
  • objectCount 节点上索引对象的总数。
• shards：分片统计信息数组。要查看 shards 详细信息，请设置 output == verbose。
  • name：分片名称。
  • class：存储在分片上的集合名称。
  • objectCount：分片上索引对象的数量。
  • vectorQueueLength：等待在分片上索引的对象数量。（从 Weaviate 1.22 开始可用，当 ASYNC_INDEXING 启用时。）

示例

以下命令将检索集群中所有节点的摘要信息

PythonJavaScript/TypeScriptGoJava v6Java v5 (已弃用)Curl

  API 文档

更多信息文档中的代码片段反映了最新的客户端库和 Weaviate 数据库版本。请查看 发行说明 以获取特定版本。

如果某个片段无法工作或您有任何反馈，请打开一个 GitHub issue。

import weaviate

client = weaviate.connect_to_local()

nodes_info = client.cluster.nodes(
    collection="JeopardyQuestion",  # If omitted, all collections will be returned
    output="verbose",  #  If omitted, will be "minimal"
)
print(nodes_info)

client.close()

import weaviate from 'weaviate-client';

const client = await weaviate.connectToLocal()

const response = await client.cluster.nodes({
  collection: 'JeopardyQuestion',
  output: 'minimal'
})

console.log(response)

package main

import (
  "context"
  "fmt"

  "github.com/weaviate/weaviate-go-client/v5/weaviate"
)

func main() {
  cfg := weaviate.Config{
    Host:   "localhost:8080",
    Scheme: "http",
  }
  client, err := weaviate.NewClient(cfg)
  if err != nil {
    panic(err)
  }

  nodesStatus, err := client.Cluster().
    NodesStatusGetter().
    Do(context.Background())

  if err != nil {
    panic(err)
  }
  fmt.Printf("%v", nodesStatus)
}

WeaviateClient client = WeaviateClient
    .connectToLocal(config -> config.host("127.0.0.1").port(8080));

System.out.println(client.cluster.listNodes()); // all
System.out
    .println(client.cluster.listNodes(n -> n.collection("MyCollection")
        .shard("MyShard")
        .verbosity(NodeVerbosity.MINIMAL)));

client.close(); // Free up resources
WeaviateClient client = WeaviateClient.connectToLocal();

System.out.println(client.meta()); // all

client.close(); // Free up resources

package io.weaviate;

import io.weaviate.client.Config;
import io.weaviate.client.WeaviateClient;
import io.weaviate.client.base.Result;
import io.weaviate.client.v1.cluster.model.NodesStatusResponse;

public class App {
  public static void main(String[] args) {
    Config config = new Config("http", "localhost:8080");
    WeaviateClient client = new WeaviateClient(config);

    Result<NodesStatusResponse> result = client.cluster()
      .nodesStatusGetter()
      .run();

    if (result.hasErrors()) {
      System.out.println(result.getError());
      return;
    }
    System.out.println(result.getResult());
  }
}

curl https://:8080/v1/nodes

示例输出

{
  "nodes": [
    {
      "batchStats": {
        "ratePerSecond": 0
      },
      "gitHash": "e6b37ce",
      "name": "weaviate-0",
      "stats": {
        "objectCount": 0,
        "shardCount": 2
      },
      "status": "HEALTHY",
      "version": "1.22.1"
    },
    {
      "batchStats": {
        "ratePerSecond": 0
      },
      "gitHash": "e6b37ce",
      "name": "weaviate-1",
      "stats": {
        "objectCount": 1,
        "shardCount": 2
      },
      "status": "HEALTHY",
      "version": "1.22.1"
    },
    {
      "batchStats": {
        "ratePerSecond": 0
      },
      "gitHash": "e6b37ce",
      "name": "weaviate-2",
      "stats": {
        "objectCount": 1,
        "shardCount": 2
      },
      "status": "HEALTHY",
      "version": "1.22.1"
    }
  ]
}

问题和反馈

如果您有任何问题或反馈，请在 用户论坛 中告诉我们。

技术问题

如果您有任何问题，请在我们的 社区论坛 上发帖。

文档反馈

通过打开 GitHub issue 提供反馈。