Обмен данными через Yandex Data Streams

В этом решение показан простой способ взаимодействия между приложениями через Yandex Data Streams:

• Producer отправляет данные в поток DataStream.
• Consumer читает данные из потока DataStream.
• Shared общая библиотека классов.

Установка пакетов

AWSSDK.Kinesis пакет SDK for .NET для Amazon Kinesis совместимый с Yandex Data Streams.

Install-Package AWSSDK.Kinesis

Пакеты для загрузки конфигурации.

Install-Package Microsoft.Extensions.Configuration
Install-Package Microsoft.Extensions.Configuration.Json

Настройки

1. Выполните создание потока.
2. Создайте сервисный аккаунт.
3. Отредактировать файл appsettings.json.

• YC_Key_ID — статический ключ доступа. Замените *** на ключ, полученный на втором шаге.
• YC_Key_secret — секрет статического ключа доступа. Замените *** на секрет, полученный на втором шаге.
• адрес сервиса serviceURL: https://yds.serverless.yandexcloud.net.
• регион сервиса region: ru-central1.
• Идентификатор folder, в котором находится поток, например: b1g82kppqsd2m076av7h.
• Идентификатор database Yandex Managed Service for YDB с потоком, например: etnp67d2bn66i70i0qav.
• Имя потока данных streamName, например yads.

{
  "YandexCloudDataStreamConfiguration": {
    "YC_Key_ID": "***",
    "YC_Key_secret": "***",
    "serviceURL": "https://yds.serverless.yandexcloud.net",
    "region": "ru-central1",
    "folder": "b1g82kppqsd2m076av7h",
    "database": "etnp67d2bn66i70i0qav",
    "streamName": "yads"
  }
}