Dados de Time Series

Visão geral

Neste guia, você pode aprender como usar o driver Java Reactive Streams para armazenar e interagir com dados de séries temporais.

Os dados de série temporal são compostos pelos seguintes componentes:

• Quantidade medida

• Carimbo de data/hora para a medição

• Metadados que descrevem a medição

A tabela a seguir descreve situações de exemplo para as quais você pode armazenar dados de série temporal:

Crie uma coleção de séries temporais

Você pode criar uma coleção de séries temporais para armazenar dados de séries temporais. Para criar uma coleção de séries temporais, passe os seguintes parâmetros para o método createCollection() :

• O nome da nova collection a ser criada

• Uma CreateCollectionOptions objeto com as TimeSeriesOptions definir com o timeSeriesOptions() método

O exemplo seguinte cria uma coleção de séries temporais denominada october2024 no banco de banco de dados do fall_weather com a opção timeField definida para o campo "timestamp" :

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

Para verificar se você criou com sucesso a time-series collection, execute o método listCollections() no reconhecimento de data center e imprima os resultados:

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}}}}
...

Armazenar dados de série temporal

Você pode inserir dados em uma coleção de séries temporais usando os métodos insertOne() ou insertMany() e especificando a medida, o carimbo de data/hora e os metadados em cada documento inserido.

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();

Consultar dados de série temporal

Você pode usar a mesma sintaxe e convenções para consultar os dados armazenados em uma coleção de séries temporais que você usa ao executar operações de leitura ou agregação em outras collections. Para saber mais sobre essas operações, consulte a seção Informações adicionais .

Informações adicionais

Para saber mais sobre os conceitos mencionados neste guia, consulte as seguintes entradas de manual do MongoDB Server :

• Séries temporais

• Criar e consultar uma coleção de séries temporais

• Definir granularidade para dados de série temporal

Para saber mais sobre como realizar operações de leitura, consulte Ler dados do MongoDB.

Para saber mais sobre como executar operações de agregação , consulte o guia Estrutura de agregação .