Fluxos de change streams

Visão geral

Neste guia, você pode aprender como usar um change stream para monitorar alterações em tempo real em seus dados. Um change stream é um recurso do MongoDB Server que permite que sua aplicação assine alterações de dados em uma única collection, reconhecimento de data center ou sistema.

Você pode abrir um change stream para ajudar a executar as seguintes ação:

• Habilite os dispositivos para rastrear e React a evento, como máquinas de detecção de movimento

• Crie um aplicativo que monitore as mudanças nos preços das ações

• Gere um registro da atividade dos funcionários para tarefas específicas

Você pode especificar um conjunto de operadores de agregação para filtrar e transformar os dados que seu aplicativo recebe. Quando conectado a um sistema MongoDB v6.0 ou posterior, você também pode configurar os eventos para incluir os dados do documento antes e depois da alteração.

Para saber como abrir e configurar um change stream, navegue até as seguintes seções:

• Dados de amostra

• Abrir um fluxo de alterações

• Aplique operadores de agregação ao seu change stream

• Incluir pré-imagens e pós-imagens

• Informações adicionais

Dados de amostra

The examples in this guide monitor changes to the directors collection. Suponha que essa collection contenha os seguintes documento, que são modelados como estruturas:

let docs = vec! [
    Director {
        name: "Todd Haynes".to_string(),
        movies: vec! ["Far From Heaven".to_string(), "Carol".to_string()],
        oscar_noms: 1,
    },
    Director {
        name: "Jane Campion".to_string(),
        movies: vec! ["The Piano".to_string(), "Bright Star".to_string()],
        oscar_noms: 5,
    }
];

Abrir um fluxo de alterações

Você pode abrir um fluxo de alterações para assinar tipos específicos de alterações de dados e produzir eventos de alteração em seu aplicativo.

Para abrir um change stream, chame o método watch() em uma instância Collection, Database ou Client .

O tipo de estrutura no qual você chama o método watch() determina o escopo de eventos que o change stream escuta. A tabela a seguir descreve o comportamento do método watch() com base em seu objeto de chamada:

let mut change_stream = my_coll.watch().await?;
while let Some(event) = change_stream.next().await.transpose()? {
    println!("Operation performed: {:?}", event.operation_type);
    println!("Document: {:?}", event.full_document);
}

Operation performed: Insert
Document: Some(Director { name: "Wes Anderson", movies: [...], oscar_noms: 7 })

Aplique operadores de agregação ao seu change stream

Você pode encadear o método pipeline() ao método watch() para especificar quais eventos de alteração o change stream recebe. Passe um aggregation pipeline como parâmetro para pipeline().

Para saber quais operadores de aggregation sua versão do servidor MongoDB suporta, consulte Modificar a saída do change stream no manual do servidor.

let mut update_change_stream = my_coll.watch()
    .pipeline(vec![doc! { "$match" : doc! { "operationType" : "update" } }])
    .await?;
while let Some(event) = update_change_stream.next().await.transpose()? {
    println!("Update performed: {:?}", event.update_description);
}

Update performed: Some(UpdateDescription { updated_fields: Document({
"oscar_noms": Int64(2)}), removed_fields: [], truncated_arrays: Some([]) })

Incluir pré-imagens e pós-imagens

Você pode configurar o evento de alteração para conter ou omitir os seguintes dados:

• Pré-imagem: um documento que representa a versão do documento antes da operação, se houver

• Pós-imagem: um documento que representa a versão do documento após a operação, se existir

Para receber evento de change stream que incluem uma pré-imagem ou pós-imagem, você deve executar a seguinte ação:

• Habilite pré-imagens e pós-imagens para a coleção em seu sistema do MongoDB.

  Dica

  Para saber como ativar as pré e pós-imagens em sua implantação, consulte Fluxo de alterações com pré e pós-imagens de documentos no manual do servidor.

  Para saber como instruir o driver a criar uma collection com pré-imagens e pós-imagens habilitadas, consulte a seção Criar uma collection com pré-imagem e pós-imagens habilitadas desta página.

• Configure seu change stream para recuperar as pré-imagens e as pós-imagens ou as duas imagens. Durante essa configuração, você pode instruir o driver a exigir pré e pós-imagens ou incluí-las somente quando disponíveis.

  Dica

  Para configurar seu change stream para registrar a pré-imagem em eventos de alteração, consulte o Exemplo de configuração de pré-imagem nesta página.

  Para configurar seu change stream para registrar a pós-imagem em eventos de alteração, consulte o Exemplo de configuração pós-imagem nesta página.

let enable = ChangeStreamPreAndPostImages::builder().enabled(true).build();
let result = my_db.create_collection("directors")
    .change_stream_pre_and_post_images(enable)
    .await?;

let pre_image = FullDocumentBeforeChangeType::Required;
let mut change_stream = my_coll.watch()
    .full_document_before_change(pre_image)
    .await?;
while let Some(event) = change_stream.next().await.transpose()? {
    println!("Operation performed: {:?}", event.operation_type);
    println!("Pre-image: {:?}", event.full_document_before_change);
}

Operation performed: Update
Pre-image: Some(Director { name: "Jane Campion", movies: ["The Piano",
"Bright Star"], oscar_noms: 5 })

let post_image = FullDocumentType::WhenAvailable;
let mut change_stream = my_coll.watch()
    .full_document(post_image)
    .await?;
while let Some(event) = change_stream.next().await.transpose()? {
    println!("Operation performed: {:?}", event.operation_type);
    println!("Post-image: {:?}", event.full_document);
}

Operation performed: Delete
Post-image: None

Informações adicionais