从 Logstash 迁移
您可以使用 Logstash 配置来运行 OpenSearch Data Prepper。
如OpenSearch Data Prepper 入门中所述,您需要使用 pipelines.yaml 文件配置 Data Prepper 管道。
或者,您可以使用 Logstash 配置 logstash.conf 来配置 Data Prepper,而不是使用 pipelines.yaml。
支持的插件
截至 Data Prepper 1.2 版本,Logstash 配置中的以下插件受支持
- HTTP 输入插件
- Grok 过滤器插件
- Elasticsearch 输出插件
- Amazon Elasticsearch 输出插件
限制
- 除支持的插件外,Logstash 配置中的所有其他插件都将抛出
Exception并无法运行。 - 截至 Data Prepper 1.2 版本,Logstash 配置中的条件语句不受支持。
使用 Logstash 配置运行 Data Prepper
-
要安装 Data Prepper 的 Docker 镜像,请参阅OpenSearch Data Prepper 入门中的“安装 Data Prepper”。
-
通过提供您的
logstash.conf配置,运行在步骤 1 中安装的 Docker 镜像。
docker run --name data-prepper -p 4900:4900 -v ${PWD}/logstash.conf:/usr/share/data-prepper/pipelines.conf opensearchproject/data-prepper:latest pipelines.conf
通过将 Logstash 配置中的插件和属性映射到 Data Prepper 中相应的插件和属性,logstash.conf 文件将转换为 logstash.yaml。您可以在存储 logstash.conf 的同一目录中找到转换后的 logstash.yaml 文件。
终端中的以下输出表明 Data Prepper 正在正常运行
INFO org.opensearch.dataprepper.pipeline.ProcessWorker - log-pipeline Worker: No records received from buffer