当前位置: 首页 > 知识库问答 >
问题:

在“重新启动错误”时间戳上记录输入mongodb循环

濮阳赞
2023-03-14

我尝试使用mongodb插件作为logstash的输入。以下是我的简单配置:

input {
    mongodb {
        uri => 'mongodb://localhost:27017/testDB'
        placeholder_db_dir => '/Users/TEST/Documents/WORK/ELK_Stack/LogStash/data/'
        collection => 'logCollection_ALL'
        batch_size => 50
    }
}
filter {}
output { stdout {} }

但是我面临一个“循环问题”,可能是由于一个字段“时间戳”,但我不知道该怎么办。

[2018-04-25T12:01:35998][WARN][logstash.inputs.mongodb]mongodb Input引发异常,重新启动{:exception=

还有一个调试日志:

[2018-04-25T12:01:34.893000#2900]调试--:MONGODB | QUERY | namespace=testDB。logCollection_ALL selector={:_id=

我如何参数化我的logstash配置,以便在标准输出控制台中获得输出?

共有1个答案

黄鸣
2023-03-14

这是因为字段@timestamp具有ISODate数据类型。

您必须从所有文档中删除此字段。

db.getCollection('collection1').update({}, {$unset: {"@timestamp": 1}}, {multi: true})
 类似资料:
  • 我使用处理器API创建kafka流媒体应用程序。 下面是我如何创建一个主题,将时间戳附加到所有传入消息 Kafka主题。sh--创建--zookeeper localhost:2181--复制因子1--分区1--主题topicName--配置消息。时间戳。类型=创建时间 工作流处理来自源主题的传入消息并将其发布到接收器主题。出于某种奇怪的原因,我在源主题和接收器主题消息中看到了相同的时间戳。例如,

  • 我正在尝试重新启动时循环。我已经声明了布尔类型的变量保去。如果int变量x不在窗口中,保去将变为假。然后重置()方法必须保持去=真。它可以工作,但同时循环不工作。 使用reset()和checkWin()初始化: 第二类带有线程、保持和时循环:

  • 问题内容: 如果我在类型表中具有一列并且具有默认值:CURRENT_TIMESTAMP如果我更新同一行中 任何 其他列的值,此列是否会更新为当前时间戳? 似乎没有,但是我不确定这是否应该发生。 我不明白这是什么意思(来自MySQL文档): 如果该列是自动更新的,则当该行中任何其他列的值从其当前值更改时,它将自动更新为当前时间戳。如果所有其他列均设置为其当前值,则该列保持不变。为防止当其他列更改时该

  • 希望有人知道这一点或者能给我指出正确的方向... 我有一个通过应用编程接口REST请求创建的数据主题。REST请求中收到的一个字段是记录事件时间的时间戳。这些记录被生成给Kafka,事件时间被设置为记录的元数据时间戳。 我还有另一个规则主题,它提供了通过向接收的值添加新字段来扩充数据主题记录的信息。 这两个主题都有用于加入的匹配键。 我的目标是使用processor API在所有处理阶段保留数据主

  • 问题内容: 我有: 但这似乎不起作用。有没有办法重新启动循环? 谢谢 问题答案: 您可能要考虑使用适用于该逻辑的其他类型的循环,因为这是最明显的答案。 也许一个:

  • 我在尝试重新启动JDEV上的IWLS时遇到以下错误 C:\users\c-sutipirn\system11.1.2.2.39.61.83.1\defaultdomain\bin\startweBlogic.cmd[等待服务器完成初始化...]此时\java\jdk1.7.0_25是意外的。进程已退出。 C:\Oracle\Product\11.2.0\Client_2\bin;C:\Progra