如何从流利记录器中的文件中获取数据



我有一个python代码在后台作为服务运行。它生成一个包含 json 数据的data.json文件,如下所示

{
"Type":"Data"
"Name":"XYZ"
"Level":32
}

此数据每 120 秒更新一次。因此,每 120 秒之后,data.json中的标签都有新值。我希望通过流利记录器的输入插件读取此信息,但不确定在此处使用哪个插件。我不能使用tail因为我没有将任何东西拖入此文件。任何人都可以建议或推荐我良好的链接/教程。

谢谢

我认为您的用例的最佳解决方案是使用 exec 插件 .
您可以使用此插件编写一个脚本,该脚本将相关密钥打印到 stdout 并由 fluentd 收集。这对你有用吗?

例-

<source>
@type exec
command node json_parser.js
run_interval 120s
</source>

然后,您可以在json_parser.js中编写解析 json 的整个逻辑,并使用console.log语句打印您希望由 fluentd 摄取的值。

最新更新