Elasticsearch 摄入节点

有时需要在索引文档之前转换它。 因此，您需要使用摄取节点在实际索引发生之前预处理文档。 例如，如果我们想要重命名一个字段并对其进行索引，或者从文档中删除一个字段，所有这些操作都由摄取节点处理。 在集群中，所有节点都具有摄取能力，但必须对其进行自定义才能由特定节点处理。 我们需要按照一些步骤来摄取节点。

涉及的步骤

基本上，摄取节点的工作涉及两个步骤 -

1. 创建管道
2. 创建文档

我们将详细讨论这两个步骤。

创建管道

首先，我们需要创建一个包含处理器的管道。 我们将以管道创建为例，其中我们将注册字段的内容转换为整数类型。 为此，请在 Elasticsearch 插件中运行以下代码以执行管道 -

复制代码

响应

如果得到的响应与下面的输出相同，则代码执行成功。

截图

创建文档

创建管道后，下一步是创建文档。 因此，我们将使用管道转换器创建一个文档。 执行以下代码 -

复制代码

响应

如果得到的响应与下面的输出相同，则代码执行成功。

截图

现在，我们将从上面创建的索引中获取文档。 为此，请使用 GET 命令，如下所示 -

复制代码

响应

如果得到的响应与下面的输出相同，则代码执行成功。

在这里，在上面的输出中，您可以看到注册字段已转换为整数。

没有管道

如果没有管道创建，整数类型值将不会转换为整数。 查看下面不使用管道创建索引的示例。

复制代码

响应

如果得到的响应与下面的输出相同，则代码执行成功。

获取文档

复制代码

响应

通过运行上面的代码，如果得到的响应与下面的输出相同，则代码执行成功。

在这里，在上面的输出中，您可以看到注册字段值 "25" 尚未转换为整数。 它是一个字符串，在没有管道的情况下打印在反引号 " " 之间。