cat transforms API编辑

cat API 仅适用于使用命令行或 Kibana 控制台的人类使用。它们适用于应用程序。对于应用程序使用,请使用 获取 transforms API

返回有关 transforms 的配置和使用信息。

请求编辑

GET /_cat/transforms/<transform_id>

GET /_cat/transforms/_all

GET /_cat/transforms/*

GET /_cat/transforms

先决条件编辑

  • 如果启用了 Elasticsearch 安全功能,则必须具有 monitor_transform 集群权限才能使用此 API。内置的 transform_user 角色具有这些权限。有关更多信息,请参阅 安全权限内置角色

路径参数编辑

<transform_id>
(可选,字符串) transform 的标识符。它可以是 transform 标识符或通配符表达式。如果您未指定这些选项之一,则 API 将返回所有 transforms 的信息。

查询参数编辑

allow_no_match

(可选,布尔值) 指定当请求时该怎么做

  • 包含通配符表达式,并且没有与之匹配的 transforms。
  • 包含 _all 字符串或没有标识符,并且没有匹配项。
  • 包含通配符表达式,并且只有部分匹配项。

默认值为 true,当没有匹配项时返回一个空的 transforms 数组,当有部分匹配项时返回结果子集。

如果此参数为 false,则当没有匹配项或只有部分匹配项时,请求将返回 404 状态代码。

format
(可选,字符串) HTTP accept 标头 的简短版本。有效值包括 JSON、YAML 等。
from
(可选,整数) 跳过指定数量的 transforms。默认值为 0
h

(可选,字符串) 要显示的列名列表,用逗号分隔。

如果您未指定要包含哪些列,则 API 将返回默认列。如果您显式指定一个或多个列,则它将仅返回指定的列。

有效列为

changes_last_detection_time, cldt
(默认) 在源索引中最后检测到更改的时间戳。
checkpoint, cp
(默认) 检查点的序列号。
checkpoint_duration_time_exp_avg, cdtea, checkpointTimeExpAvg
检查点持续时间的指数移动平均值,以毫秒为单位。
checkpoint_progress, c, checkpointProgress
(默认) 当前正在进行的下一个检查点的进度。
create_time, ct, createTime
创建 transform 的时间。
delete_time, dtime
删除所花费的时间,以毫秒为单位。
description, d
transform 的描述。
dest_index, di, destIndex
transform 的目标索引

对于 pivot transform,目标索引的映射在可能的情况下根据源字段推断。如果需要备用映射,请在启动 transform 之前使用 创建索引 API

对于 latest transform,永远不会推断映射。如果目标索引的动态映射不可取,请在启动 transform 之前使用 创建索引 API

documents_deleted, docd
由于此 transform 的保留策略,已从目标索引中删除的文档数量。
documents_indexed, doci
已索引到 transform 目标索引中的文档数量。
docs_per_second, dps
指定每秒输入文档数量的限制。此设置通过在搜索请求之间添加等待时间来限制 transform。默认值为 null,它将禁用限制。
documents_processed, docp
(默认) 已从 transform 源索引中处理的文档数量。
frequency, f
transform 持续运行时,检查源索引中更改的间隔。最小值为 1s,最大值为 1h。默认值为 1m
id
(默认) transform 的标识符。
index_failure, if
索引失败的数量。
index_time, itime
索引所花费的时间,以毫秒为单位。
index_total, it
索引操作的数量。
indexed_documents_exp_avg, idea
已索引的新文档数量的指数移动平均值。
last_search_time, lst, lastSearchTime
(默认) 源索引中最后一次搜索的时间戳。此字段仅在 transform 运行时显示。
max_page_search_size, mpsz
定义每个检查点用于复合聚合的初始页面大小。如果发生断路器异常,则页面大小会动态调整为较低的值。最小值为 10,最大值为 65,536。默认值为 500
pages_processed, pp
已处理的搜索或批量索引操作的数量。文档是分批处理的,而不是单独处理的。
pipeline, p
摄取管道 的唯一标识符。
processed_documents_exp_avg, pdea
已处理的文档数量的指数移动平均值。
processing_time, pt
处理结果所花费的时间,以毫秒为单位。
reason, r
如果 transform 处于 failed 状态,则此属性提供有关失败原因的详细信息。
search_failure, sf
搜索失败的数量。
search_time, stime
搜索所花费的时间,以毫秒为单位。
search_total, st
对 transform 源索引执行的搜索操作的数量。
source_index, si, sourceIndex

(默认) transform 的源索引。它可以是单个索引、索引模式(例如,"my-index-*")、索引数组(例如,["my-index-000001", "my-index-000002"])或索引模式数组(例如,["my-index-*", "my-other-index-*"]。对于远程索引,请使用语法 "remote_name:index_name"

如果任何索引位于远程集群中,则主节点和至少一个 transform 节点必须具有 remote_cluster_client 节点角色。

state, s

(默认) transform 的状态,可以是以下值之一

  • aborting: transform 正在中止。
  • failed: transform 失败。有关失败的更多信息,请检查 reason 字段。
  • indexing: transform 正在积极处理数据并创建新文档。
  • started: transform 正在运行,但没有积极索引数据。
  • stopped: transform 已停止。
  • stopping: transform 正在停止。
transform_type, tt
指示 transform 的类型:batchcontinuous
trigger_count, tc
transform 由调度程序触发的次数。例如,调度程序会触发 transform 索引器以指定间隔检查更新或摄取新数据,该间隔在 frequency 属性 中指定。
version, v

创建 transform 时节点上存在的 Elasticsearch 版本。

help
(可选,布尔值) 如果为 true,则响应将包含帮助信息。默认为 false
s
(可选,字符串) 用逗号分隔的列名或列别名列表,用于对响应进行排序。
size
(可选,整数) 指定要获取的最大 transform 数量。默认值为 100
time
(可选,时间单位) 用于显示时间值的单位。
v
(可选,布尔值) 如果为 true,则响应将包含列标题。默认为 false

示例编辑

response = client.cat.transforms(
  v: true,
  format: 'json'
)
puts response
GET /_cat/transforms?v=true&format=json
[
  {
    "id" : "ecommerce_transform",
    "state" : "started",
    "checkpoint" : "1",
    "documents_processed" : "705",
    "checkpoint_progress" : "100.00",
    "changes_last_detection_time" : null
  }
]