比较尼菲的时间是可能的吗?

Compare the hours in Nifi is possible?

我输入的日期时间如下所示。,

1,23.01.2016 09:02:21,Mega,201
2,02.01.2016 10:02:23,Hema,202

现在我需要获取第 2 列 ["02.01.2016 10:02:23"],然后将其与当前日期时间(以毫秒为单位)进行比较。

之后,如果第 2 列在过去 72 小时之间,然后插入 sql 服务器。

如何比较数据的小时数与当前日期时间的小时数?

您的数据似乎是 CSV 格式,因此您可以尝试使用 RouteOnContent 处理器和正则表达式从文件中提取日期时间列, 您可以将您的内容转换为 AVRO 格式,然后将 AVRO 转换为 JSON 并拆分文件,以便您可以单独提取 dateTime 作为属性。

使用您的数据作为输入您将:

  • InferAvroSchema(假设您上面的布局是标准的)
  • ConvertCSVToAvro(使用推断模式)
  • ConvertAvroToJSON
  • 拆分JSON
  • 评估JSON路径(取出日期时间属性并设置为属性)
  • RouteOnAttribute(比较dateTime属性和你想要的系统日期)

系统日期 - 72 小时可以通过以下方式以编程方式计算:

${now():toNumber():minus(259200000):format('dd.mm.yyyy hh:mm:ss')}