时间序列数据

Overview

在本指南中，您可以学习；了解如何使用Java Reactive Streams驾驶员来存储时间序列数据并交互。

时间序列数据由以下部分组成：

• 测量数量

• 测量的时间戳

• 描述测量的元数据

下表描述了可以存储时间序列数据的示例情况：

创建时间序列集合

您可以创建时间序列集合来存储时间序列数据。 要创建时间序列集合，请将以下参数传递给 createCollection()方法：

• 要创建的新集合的名称

• CreateCollectionOptions 对象与 TimeSeriesOptions 使用timeSeriesOptions() 方法设立

以下示例在fall_weather数据库中创建名为october2024的时间序列集合，并将timeField选项设立为"timestamp"字段：

MongoDatabase database = mongoClient.getDatabase("fall_weather");
TimeSeriesOptions tsOptions = new TimeSeriesOptions("timestamp");
CreateCollectionOptions collectionOptions = new CreateCollectionOptions().timeSeriesOptions(tsOptions);
database.createCollection("october2024", collectionOptions);

要验证是否已成功创建time-series collection，请对数据库运行listCollections()方法并打印结果：

ListCollectionsPublisher<Document> listCollectionsPublisher = database.listCollections();
Flux.from(listCollectionsPublisher)
        .doOnNext(System.out::println)
        .blockLast();

Document{{name=october2024, type=timeseries, options=Document{{timeseries=Document{{timeField=timestamp, granularity=seconds, bucketMaxSpanSeconds=3600}}}}, info=Document{{readOnly=false}}}}
...

存储时间序列数据

您可以使用insertOne()或insertMany()方法将数据插入到时间序列集合中，并在每个插入的文档中指定测量值、时间戳和元数据。

MongoCollection<Document> collection = database.getCollection("october2024");
// Temperature data for October 1, 2024
Document temperature1 = new Document("temperature", 54)
        .append("location", "New York City")
        .append("timestamp", new Date(1727755200000L));
// Temperature data for October 2, 2024
Document temperature2 = new Document("temperature", 55)
        .append("location", "New York City")
        .append("timestamp", new Date(1727841600000L));
Publisher<InsertManyResult> insertPublisher =
        collection.insertMany(Arrays.asList(temperature1, temperature2));
Mono.from(insertPublisher).block();

查询时间序列数据

您可以使用与对其他集合执行读取或聚合操作时相同的语法和约定来查询时间序列集合中存储的数据。 要学习；了解有关这些操作的更多信息，请参阅“其他信息”部分。

更多信息

要学习；了解有关本指南中提到的概念的更多信息，请参阅以下MongoDB Server手册条目：

• 时间序列

• 创建和查询时间序列集合

• 设置时间序列数据的粒度

要学习；了解有关执行读取操作的更多信息，请参阅从MongoDB读取数据。

要学习；了解有关执行聚合操作的更多信息，请参阅聚合框架指南。