Como executar pesquisa de query no Atlas Search do utilizando visualizações materializadas

No Atlas, VáGo para a Triggers página do seu projeto.

1. Se ainda não tiver sido exibido, selecione a organização que contém seu projeto no menu Organizations na barra de navegação.

2. Se ainda não estiver exibido, selecione seu projeto no menu Projects na barra de navegação.

3. Na barra lateral, clique em Triggers sob o título Services.

   A página Acionadores é exibida.

Clique Add a Trigger em para abrir a página de configuração do trigger.

Inserir valores de configuração para o trigger.

Crie a função.

A função para este trigger define uma visualização materializada monthlyPhoneTransactions que contém informações de vendas mensais cumulativas. A função atualiza as informações de vendas mensais para vendas realizadas por telefone.

Cole o seguinte código na função:

exports = function(){
   var pipeline = [
     { $match: {purchaseMethod: "Phone"} },
     { $unwind: {path: "$items"}},
     { $group: {
      _id: { $dateToString:
      { format: "%Y-%m", date: "$saleDate" } },
      sales_quantity: { $sum: "$items.quantity"},
      sales_price: { $sum: "$items.price"}
     }},
     { $set: { sales_price: { $toDouble: "$sales_price"}}},
     { $merge: { into: "monthlyPhoneTransactions", whenMatched: "replace" } }
   ]
   var monthlyPhoneTransactions = context.services.get("mongodb-atlas").db("sample_supplies").collection("sales");
   return monthlyPhoneTransactions.aggregate(pipeline);
};

A função utiliza os seguintes estágios do aggregation pipeline para atualizar monthlyPhoneTransactions:

• O estágio $match filtra os dados para processar somente as vendas que foram concluídas no Phone.

• A etapa $group agrupa as informações de vendas por ano-mês. Esta etapa gera documentos do formulário:

  { "_id" : "<YYYY-mm>", "sales_quantity" : <num>, "sales_amount" : <NumberDecimal> }

• O estágio $set altera o tipo de dados do campo sales_price para double. Os operadores $search do Atlas Search não são compatíveis com o tipo de dados Decimal128. Alterar o tipo de dados do campo sales_price permite fazer query deste campo utilizando índices de pesquisa do Atlas Search.

• O estágio $merge grava a saída na coleção monthlyPhoneTransactions.

  Com base no campo _id, o estágio verifica se o documento nos resultados de agregação corresponde a um documento existente na coleção:

  • Quando o Atlas Search encontra uma correspondência (ou seja, um documento com o mesmo ano-mês já existe na coleção), o Atlas Search substitui o documento existente pelo documento dos resultados da agregação, conforme especificado no estágio.

  • Quando o Atlas Search não encontra uma correspondência, o Atlas Search insere o documento dos resultados da agregação na coleção conforme especificado no estágio.

Teste a função.

Clique no botão Run no canto inferior direito do Function Editor para criar a visualização materializada de monthlyPhoneTransactions.

A aba Result na parte inferior do Function Editor reflete o status de execução da função. Clique em Save Draft.

No Atlas, váGo para a Triggers página do seu projeto.

1. Se ainda não tiver sido exibido, selecione a organização que contém seu projeto no menu Organizations na barra de navegação.

2. Se ainda não estiver exibido, selecione seu projeto no menu Projects na barra de navegação.

3. Na barra lateral, clique em Triggers sob o título Services.

   A página Acionadores é exibida.

Clique Add a Trigger em para abrir a página de configuração do trigger.

Inserir valores de configuração para o trigger.

Crie a função.

exports = function(){
   var pipeline = [
     { $match: {purchaseMethod: "Phone"} },
     { $unwind: {path: "$items"}},
     { $group: {
      _id: { $dateToString:
      { format: "%Y-%m", date: "$saleDate" } },
      sales_quantity: { $sum: "$items.quantity"},
      sales_price: { $sum: "$items.price"}
     }},
     { $set: { sales_price: { $toDouble: "$sales_price"}}},
     { $merge: { into: "monthlyPhoneTransactions", whenMatched: "replace" } }
   ]
   var monthlyPhoneTransactions = context.services.get("mongodb-atlas").db("sample_supplies").collection("purchaseOrders");
   return monthlyPhoneTransactions.aggregate(pipeline);
};

Teste a função.

Clique no botão Run no canto inferior direito do Function Editor para atualizar a visualização materializada de monthlyPhoneTransactions.

A guia Result na parte inferior do Function Editor reflete o status de execução da função.

A função updateMonthlyPurchaseOrders atualiza a exibição materializada monthlyPhoneTransactions com os dados da ordem de compra de janeiro de 2018.

Clique em Save.

Revise e implante o rascunho do aplicativo Sales-App.

Use mongosh para consultar a coleção monthlyPhoneTransactions para confirmar a atualização:

db.monthlyPhoneTransactions.find().sort( { _id: -1} )

{
  _id: '2018-01',
  sales_quantity: 66,
  sales_price: Decimal128("1407.10")
}

A visualização materializada monthlyPhoneTransactions mostra os dados recém-adicionados. O resultado principal indica que a transação mais recente ocorreu em janeiro de 2018.

Revise e implante o rascunho do aplicativo Sales-App.