比较尼菲的时间是可能的吗?
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')}
我输入的日期时间如下所示。,
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')}