Поделиться через

Доступ, создание или обработка документов в Azure Cosmos DB с рабочими процессами в Azure Logic Apps

  • Статья

Область применения: Azure Logic Apps (Потребление + Стандарт)

Из рабочего процесса в Azure Logic Apps можно подключиться к Azure Cosmos DB и работать с документами с помощью соединителя Azure Cosmos DB . Например, можно использовать операции соединителя для создания, обновления, чтения, запроса или удаления документов.

Вы можете подключиться к Azure Cosmos DB из рабочих процессов приложений логики "Потребление" и "Стандартный", используя управляемые операции соединителя, которые размещаются, управляются и выполняются в глобальной мультитенантной среде Azure. Для стандартных рабочих процессов Azure Cosmos DB также предоставляет встроенные операции , которые выполняются вместе со средой выполнения для Azure Logic Apps с одним клиентом. Встроенные операции обеспечивают более высокую производительность, более высокую пропускную способность и иногда разные функции. Например, в рабочем процессе уровня "Стандартный" можно использовать встроенный триггер для мониторинга контейнера Azure Cosmos DB для новых или обновленных элементов. Вы можете объединить операции Azure Cosmos DB с другими пользователями в рабочем процессе для поддержки таких сценариев, как источник событий и общая обработка данных.

Ограничения

  • В настоящее время только рабочие процессы состояния типа "Стандартный" могут использовать как операции управляемого соединителя, так и встроенные операции. Безгосударственные рабочие процессы могут использовать только встроенные операции.

  • Соединитель Azure Cosmos DB поддерживает только учетные записи Azure Cosmos DB, созданные с помощью Azure Cosmos DB для NoSQL.

Предварительные условия

Технический справочник по соединителю

Добавление триггера Azure Cosmos DB

В Azure Logic Apps каждый рабочий процесс должен начинаться с триггера, который запускается, когда происходит определенное событие или когда выполняется определенное условие.

Если вы работаете с рабочим процессом уровня "Стандартный", встроенный триггер с именем "При создании или изменении элемента " доступен и основан на шаблоне конструктора канала изменений Azure Cosmos DB. Этот триггер недоступен для рабочих процессов потребления.

Триггеры Azure Cosmos DB недоступны для рабочих процессов потребления. Вместо этого добавьте триггер, который работает в вашем сценарии.

Добавьте действие Azure Cosmos DB

В Azure Logic Apps действие — это шаг в рабочем процессе, который следует триггеру или другому действию. Соединитель Azure Cosmos DB предлагает действия как для рабочих процессов потребления, так и для стандартных рабочих процессов. В следующих примерах показано, как использовать действие, которое создает или обновляет документ.

Чтобы добавить действие Azure Cosmos DB в рабочий процесс потребления, выполните следующие действия.

  1. На портале Azure откройте рабочий процесс потребления в конструкторе.

  2. Если рабочий процесс пуст, добавьте любой нужный триггер.

    Этот пример начинается с триггера при получении HTTP-запроса.

  3. В разделе триггера или действия, в котором вы хотите добавить действие Azure Cosmos DB, выполните следующие общие действия, чтобы добавить действие Azure Cosmos DB , которое вы хотите.

    В этом примере используется действие с именем Create or update document (V3).

  4. Если вам будет предложено получить сведения о подключении, создайте подключение к учетной записи Azure Cosmos DB.

  5. В области сведений о действии на вкладке "Параметры " укажите следующие необходимые сведения:

    Параметр Обязательное поле ценность Описание
    Имя учетной записи Azure Cosmos DB Да < Cosmos-DB-account-name> Имя учетной записи Azure Cosmos DB.
    Идентификатор базы данных Да < Cosmos-DB-database-name> База данных для подключения.
    Идентификатор коллекции Да < Cosmost-DB-container-name> Контейнер для запроса.
    Документ Да < JSON-document> Создаваемый документ JSON. В этом примере используется текст запроса из выходных данных триггера.

    Совет: Если токен Триггера HTTP Body не отображается в списке динамического содержимого для добавления, рядом с именем триггера выберите Узнать больше.

    Примечание. Убедитесь, что текст хорошо сформирован JSON, а как минимум содержит id свойство и свойство ключа секции для документа. Если документ с указанным id разделительным ключом существует, он обновляется. В противном случае создается новый документ.

    Рассмотрим пример.

    Снимок экрана: портал Azure, конструктор для рабочего процесса потребления и действие с именем

  6. Чтобы добавить другие доступные параметры, откройте список дополнительных параметров .

  7. При необходимости настройте любые другие параметры или настройки.

  8. На панели инструментов конструктора выберите Сохранить.

  9. Проверьте рабочий процесс, чтобы убедиться, что действие создает документ в указанном контейнере.

Подключение к Azure Cosmos DB

При добавлении триггера или действия, которое подключается к службе или системе, и у вас нет существующего или активного подключения, Azure Logic Apps предложит предоставить сведения о подключении, которые зависят от типа подключения, например:

  • Данные для входа в аккаунт
  • Имя, используемое для подключения
  • Имя сервера или системы
  • Тип проверки подлинности
  • Строка подключения

Прежде чем настроить триггер Azure Cosmos DB или действие Azure Cosmos DB, необходимо подключиться к учетной записи базы данных.

Для рабочего процесса потребления подключение Azure Cosmos DB требует следующей информации:

Параметр Обязательное поле значение Описание
Имя подключения Да < имя_соединения> Имя, используемое для подключения.
Тип проверки подлинности Да < тип подключения> Тип проверки подлинности. В этом примере используется ключ доступа.

— Если выбрать ключ доступа, укажите оставшиеся необходимые значения свойств для создания соединения.

— При выборе интегрированного идентификатора Microsoft Entra ID никакие другие значения свойств не требуются, но необходимо настроить подключение, выполнив действия по проверке подлинности Microsoft Entra и соединителю Azure Cosmos DB.

— Сведения о настройке управляемого удостоверения см. в статье "Проверка подлинности доступа и подключений к ресурсам Azure с управляемыми удостоверениями в Azure Logic Apps".
идентификатор учетной записи; Да < идентификатор учетной записи> Имя учетной записи Azure Cosmos DB, используемой для этого подключения.
Ключ доступа к учетной записи Azure Cosmos DB Да < ключ доступа> Ключ доступа для учетной записи Azure Cosmos DB, используемой для этого подключения. Это значение является ключом для чтения и записи или ключом только для чтения.

Примечание. Чтобы найти ключ, перейдите на страницу учетной записи Azure Cosmos DB. В меню учетной записи в разделе "Параметры" выберите "Ключи". Скопируйте одно из доступных значений ключей.

Примечание.

После создания подключения, если у вас есть другое подключение Azure Cosmos DB, которое вы хотите использовать, или если вы хотите создать новое подключение, выберите "Изменить подключение" на вкладке "Параметры " на панели сведений о триггере или действии.

Рекомендации по встроенным операциям Azure Cosmos DB

Получение итерируемых результатов из действия "Элементы запроса"

Встроенные действия запросов в рабочем процессе уровня "Стандартный" имеют множество динамических выходных данных содержимого, доступных для использования в последующих действиях. Чтобы получить элементы результата запроса или метаданные элемента в качестве итерируемого объекта, выполните следующие действия.

  1. На портале Azure откройте рабочий процесс "Стандартный" в конструкторе.

  2. Если рабочий процесс пуст, добавьте любой нужный триггер.

    В этом примере приложение запускается при срабатывании триггера повторения.

  3. В триггере или действии, в котором необходимо добавить действие Azure Cosmos DB, выполните следующие общие действия, чтобы добавить действие Azure Cosmos DB с именем "Элементы запроса".

  4. Если вам будет предложено получить сведения о подключении, создайте подключение к учетной записи Azure Cosmos DB.

  5. В области сведений о действии на вкладке "Параметры " укажите следующие необходимые сведения:

    Параметры Обязательное поле значение Описание
    Идентификатор базы данных Да < идентификатор базы данных> База данных для подключения.
    Идентификатор контейнера Да < идентификатор контейнера> Контейнер для запроса.
    Запросы SQL Да < sql-query> SQL-запрос для запроса.

    В следующем примере показано действие "Элементы запроса".

    Снимок экрана: портал Azure, конструктор рабочего процесса уровня

  6. При необходимости настройте любые другие параметры или настройки.

  7. В действии "Элементы запроса" выполните следующие общие действия, чтобы добавить действие, которое требуется выполнить для всех возвращаемых элементов запроса.

    В этом примере используется встроенное действие Azure Cosmos DB с именем Delete an item.

  8. В действии "Удалить элемент" можно получить доступ к выходным данным из действия "Элементы запроса ", выполнив следующие действия:

    1. Выберите внутри любого поля ввода, чтобы отобразить доступные параметры.

    2. Щелкните значок молнии, чтобы открыть список динамического содержимого.

    3. В разделе "Элементы запроса" в списке выберите нужный результат или выберите Другие для просмотра дополнительных результатов.

      Например, можно выбрать элемент "Элементы ответа" , чтобы заполнить поле "Идентификатор элемента" идентификаторами из результатов запроса.

      После выбора элемента элементов ответа действие 'для каждого' автоматически добавляется для перебора всех результатов запроса. В каждом цикле содержится действие "Удалить элемент".

      Снимок экрана: портал Azure, конструктор рабочего процесса уровня

  9. Добавьте в цикл любые другие действия, которые вы хотите.

  10. На панели инструментов конструктора выберите Сохранить.

  11. Проверьте рабочий процесс, чтобы убедиться, что действия возвращают ожидаемые выходные данные.

Связанный контент