如何将历史数据插入 fiware(具有正确的日期)?
How to insert historical data into fiware (with correct dates)?
我有一堆历史数据 (csv),我想通过 sth-comet 访问这些数据。数据是多次反转的水位历史记录。数据不是实时提供的,而是每天或多或少提供的,并且包含多天的所有历史记录。
到目前为止我所做的是:
- 使用
dateObserved: DateTime
和waterlevel : number
字段将数据转换为NGSIv2格式数据模型
- Update/append将数据导入Fiware orion
- 为实体类型创建对 sth-comet 的订阅
- 访问sth-comet中的历史数据(错误时间)
有了这个,我现在遇到的问题是 "rcvTime" 当然是 sth-comet
收到数据的时间。有什么方法可以 "overwrite" 该属性,或者有更好的解决方案吗?我还查看了 cygnus 的插入数据,但我认为潜在的问题是相同的。
我在可用文档中找不到任何提示。
在使用 Cygnus NGSIMongoSink 和 NGSISthSink 的情况下,您可以在属性中使用 TimeInstant
元数据,用元数据值中给定的时间覆盖接收到的时间。
By default, NGSIMongoSink
stores the notification reception timestamp. Nevertheless, if (and only if) working in row
mode and a metadata named TimeInstant
is notified, then such metadata value is used instead of the reception timestamp. This is useful when wanting to persist a measure generation time (which is thus notified as a TimeInstant
metadata) instead of the reception time.
或 NGSISTHSink documentation 中的类似片段:
By default, NGSISTHSink
stores the notification reception timestamp. Nevertheless, if a metadata named TimeInstant
is notified, then such metadata value is used instead of the reception timestamp. This is useful when wanting to persist a measure generation time (which is thus notified as a TimeInstant
metadata) instead of the reception time.
我有一堆历史数据 (csv),我想通过 sth-comet 访问这些数据。数据是多次反转的水位历史记录。数据不是实时提供的,而是每天或多或少提供的,并且包含多天的所有历史记录。
到目前为止我所做的是:
- 使用
dateObserved: DateTime
和waterlevel : number
字段将数据转换为NGSIv2格式数据模型 - Update/append将数据导入Fiware orion
- 为实体类型创建对 sth-comet 的订阅
- 访问sth-comet中的历史数据(错误时间)
有了这个,我现在遇到的问题是 "rcvTime" 当然是 sth-comet
收到数据的时间。有什么方法可以 "overwrite" 该属性,或者有更好的解决方案吗?我还查看了 cygnus 的插入数据,但我认为潜在的问题是相同的。
我在可用文档中找不到任何提示。
在使用 Cygnus NGSIMongoSink 和 NGSISthSink 的情况下,您可以在属性中使用 TimeInstant
元数据,用元数据值中给定的时间覆盖接收到的时间。
By default,
NGSIMongoSink
stores the notification reception timestamp. Nevertheless, if (and only if) working inrow
mode and a metadata namedTimeInstant
is notified, then such metadata value is used instead of the reception timestamp. This is useful when wanting to persist a measure generation time (which is thus notified as aTimeInstant
metadata) instead of the reception time.
或 NGSISTHSink documentation 中的类似片段:
By default,
NGSISTHSink
stores the notification reception timestamp. Nevertheless, if a metadata namedTimeInstant
is notified, then such metadata value is used instead of the reception timestamp. This is useful when wanting to persist a measure generation time (which is thus notified as aTimeInstant
metadata) instead of the reception time.