Можно ли вызвать запуск Космос дБ из потоковой аналитики?

Question

У меня есть несколько устройств, отправляющих данные в Azure iot hub. Я использую сервис потоковой аналитики для обработки данных и вставки их в cosmos db documentdb. Я думал об использовании триггера cosmosdb для обновления некоторых документов при создании определенных элементов, но обнаружил, что триггеры вызываются через API или SDK. Можно ли вызвать запуск Космос дБ из потоковой аналитики? другой способ решить проблему?

Answer 1

В ASA нет триггера для CosmosDb. Но как насчет использования функционального триггера Azure для CosmosDB ? Эта концепция использует ленту изменений CosmosDb, и это самый простой способ получить изменения в вашей CosmosDb. Ниже приведен один пример из документации, прилагаемой по ссылке выше.

#r "Microsoft.Azure.DocumentDB.Core"

using System;
using Microsoft.Azure.Documents;
using System.Collections.Generic;
using Microsoft.Extensions.Logging;

public static void Run(IReadOnlyList<Document> documents, ILogger log)
{
  log.LogInformation("Documents modified " + documents.Count);
  log.LogInformation("First document Id " + documents[0].Id);
}

В качестве альтернативы можно вручную проверить ленту изменений CosmosDB и внедрить решение, которое иногда принимает изменения и делает все, что вам нужно.