Elasticsearch摄取节点

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

步骤包括

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

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

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

创建管道

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

复制代码

响应

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

截图

创建文档

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

复制代码

响应

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

截图

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

复制代码

响应

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

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

没有流水线

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

复制代码

响应

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

获取文件

复制代码

响应

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

在上面的输出中，您可以看到enrollment字段值“25”尚未转换为整数。它是一个打印在倒逗号“”之间的字符串，没有流水线。