Тестирование локально с помощью эмулятора Центры событий Azure

В этой статье приведены инструкции по разработке и тестированию локально с помощью эмулятора Центры событий Azure.

Необходимые компоненты

• Рабочий стол Docker
• Минимальные требования к оборудованию:
  • 2 ГБ ОЗУ
  • 5 ГБ дискового пространства
• конфигурация подсистема Windows для Linux (WSL) (только для Windows):
  • Установка WSL
  • Настройка Docker для использования WSL

Примечание.

Прежде чем продолжить действия, описанные в этой статье, убедитесь, что Docker Desktop работает в фоновом режиме.

Запуск эмулятора

Для запуска эмулятора Центров событий можно использовать автоматический скрипт или контейнер Linux:

Автоматизированный скрипт

Перед запуском автоматизированного скрипта клонируйте репозиторий установщика установщика GitHub эмулятора локально.

Windows

Выполните следующие действия для локального запуска эмулятора Центров событий в Windows:

1. Разрешить выполнение неподписанных скриптов, выполнив следующую команду в окне PowerShell:

   $>Start-Process powershell -Verb RunAs -ArgumentList 'Set-ExecutionPolicy Bypass –Scope CurrentUser'

2. Запустите скрипт установки LaunchEmulator.ps1. При выполнении скрипта выводится два контейнера: эмулятор Центров событий и Azurite (зависимость для эмулятора).

Linux и macOS

Для локального запуска эмулятора Центров событий в Linux или macOS:

• Запустите скрипт установки LaunchEmulator.sh. При выполнении скрипта выводится два контейнера: эмулятор Центров событий и Azurite (зависимость для эмулятора).

Docker (контейнер Linux)

1. Чтобы запустить эмулятор, укажите конфигурацию для сущностей, которые требуется использовать. Сохраните следующий JSON-файл локально как config.json:

   {
       "UserConfig": {
           "NamespaceConfig": [
           {
               "Type": "EventHub",
               "Name": "emulatorNs1",
               "Entities": [
               {
                   "Name": "eh1",
                   "PartitionCount": "2",
                   "ConsumerGroups": [
                   {
                       "Name": "cg1"
                   }
                   ]
               }
               ]
           }
           ], 
           "LoggingConfig": {
               "Type": "File"
           }
       }
   }
   
   

2. Чтобы развернуть контейнеры для эмулятора Центров событий, сохраните следующий YAML-файл как docker-compose.yaml.

   name: microsoft-azure-eventhubs
   services:
     emulator:
       container_name: "eventhubs-emulator"
       image: "mcr.microsoft.com/azure-messaging/eventhubs-emulator:latest"
       volumes:
         - "${CONFIG_PATH}:/Eventhubs_Emulator/ConfigFiles/Config.json"
       ports:
         - "5672:5672"
         - "9092:9092"
       environment:
         BLOB_SERVER: azurite
         METADATA_SERVER: azurite
         ACCEPT_EULA: ${ACCEPT_EULA}
       depends_on:
         - azurite
       networks:
         eh-emulator:
           aliases:
             - "eventhubs-emulator"
     azurite:
       container_name: "azurite"
       image: "mcr.microsoft.com/azure-storage/azurite:latest"
       ports:
         - "10000:10000"
         - "10001:10001"
         - "10002:10002"
       networks:
         eh-emulator:
           aliases:
             - "azurite"
   networks:
     eh-emulator:
   

3. Создайте env-файл, чтобы объявить переменные среды для эмулятора Центров событий:

   # Centralized environment variables store for docker-compose
   
   # 1. CONFIG_PATH: Path to config.json file
   CONFIG_PATH="<Replace with path to config.json file>" 
   
   # 2. ACCEPT_EULA: Pass 'Y' to accept license terms. 
   ACCEPT_EULA="N"
   
   

   ACCEPT_EULA Аргумент подтверждает условия лицензии на программное обеспечение Майкрософт. Не забудьте поместить env-файл в тот же каталог, что и файл docker-compose.yaml .

   Внимание

   При указании путей к файлам в Windows используйте двойные обратные косые () вместо одинарных обратных косых знаков (\\\), чтобы избежать путаницы с escape-символами.

4. Чтобы запустить эмулятор, выполните следующую команду:

    docker compose -f <PathToDockerComposeFile> up -d
   

После успешного выполнения действий можно найти контейнеры, работающие в Docker.

Взаимодействие с эмулятором

По умолчанию эмулятор использует файл конфигурации config.json . Сущности (центры событий или разделы Kafka) можно настроить, внося изменения в файл конфигурации. Дополнительные сведения см. в разделе "Изменение конфигурации"

Для подключения к эмулятору Центров событий можно использовать следующие строка подключения:

• Когда контейнер эмулятора и взаимодействующее приложение выполняются на локальном компьютере, используйте следующие строка подключения:

"Endpoint=sb://localhost;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true;"

• Приложения (контейнеризованные или неконтейнеризованные) на другом компьютере и одной локальной сети могут взаимодействовать с эмулятором с помощью IPv4-адреса компьютера. Используйте следующие строка подключения:

"Endpoint=sb://192.168.y.z;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true;"

• Контейнеры приложений в той же сети моста могут взаимодействовать с эмулятором с помощью псевдонима или IP-адреса. Ниже строка подключения предполагается, что имя эмулятора имеет значение по умолчанию, которое является "eventhubs-emulator":

"Endpoint=sb://eventhubs-emulator;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true;"

• Контейнеры приложений в другой сети моста могут взаимодействовать с эмулятором с помощью host.docker.internal в качестве узла. Используйте следующие строка подключения:

"Endpoint=sb://host.docker.internal;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true;"

Использование Kafka

При взаимодействии с Kafka убедитесь, что настройте конфигурацию производителя и потребителя следующим образом:

        {
            BootstrapServers =  //Value of bootstrap servers would depend on kind of connection string being used
            SecurityProtocol = SecurityProtocol.SaslPlaintext,
            SaslMechanism = SaslMechanism.Plain,
            SaslUsername = "$ConnectionString",
            SaslPassword = //Value of connection string would depend on topology
        };

Значение bootstrapServers и SaslPassword зависит от топологии установки. Дополнительные сведения см. в разделе "Взаимодействие с эмулятором ".

Внимание

При использовании Kafka совместимы только API-интерфейсы производителя и потребителя с эмулятором Центров событий.

Использование AMQP

С помощью последних выпусков клиентского пакета SDK вы можете взаимодействовать с эмулятором на различных языках программирования. Дополнительные сведения см. в пакетах SDK клиента.

Чтобы приступить к работе, ознакомьтесь с примерами эмулятора Центров событий на GitHub.

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

Обзор эмулятора Центры событий Azure