Локализованное руководство по чтению

azure-eventhub-pyНазначение, использование и источник

SDK Azure Event Hubs для потоковой передачи данных на Python. Используется для высокопроизводительного приема событий, генерации и обработки данных, а также для создания контрольных точек. Триггеры: "event hubs", "EventHubProducerClient", "EventHubConsumerClient", "streaming", "partitions".

Источник получен: 2026-10-29

Репозиторий-источник: microsoft/skills
SKILL.md: .github/plugins/azure-sdk-python/skills/azure-eventhub-py/SKILL.md
Звёзды репозитория: 3,157
Последнее обновление репозитория: 2026-10-31
Категории Skills: Облачные сервисы
Время последнего сбора: 2026-10-31 10:38 UTC+08:00

Лицензия: MIT

Оригинальный файл SKILL.md

Приведенные фрагменты описания рабочих процессов являются вспомогательными средствами для чтения, а не исполняемыми инструкциями от Codez. Для создания этой страницы не использовались сторонние инструменты.

Приведённые ниже фрагменты, описывающие цели и рабочие процессы, представляют собой исходный материал, систематизированный и переведённый для удобства чтения. Они отличаются от отдельно обозначенного редакционного анализа Codez.

Что делает этот навык

Как работает рабочий процесс на вышестоящем уровне

SDK Azure Event Hubs для Python

Платформа для потоковой обработки больших данных с целью высокоскоростного приема событий.

проход вверх по течению · L13 ↗

Аутентификация и жизненный цикл

> 🔑 К каждому приведенному ниже примеру кода применяются два правила: > >1Это работает локально (Azure CLI / VS Code / Developer CLI) и в Azure (управляемое удостоверение, удостоверение рабочей нагрузки) без изменения кода.

проход вверх по течению · L35 ↗

Передовые методы

Выбирайте синхронный или асинхронный режим и придерживайтесь его. Не смешивайте их.azure.xxxсинхронизировать клиентов сazure.xxx.aioАсинхронные клиенты в одном и том же пути вызова. Выбирайте один режим для каждого модуля. Всегда используйте менеджеры контекста для клиентов и асинхронных учетных данных. Оберните каждого клиента вwith Client(...) as client:(синхронизация) илиasync with Client(...) as client:(асинхронный режим) для надлежащей очистки. Для асинхронного режимаDefaultAzureCredentialотazure.identity.aioтакже использоватьasync with credential:Таким образом, происходит упорядочение жетонов и транспортных средств.

проход вверх по течению · L242 ↗

Требования и настройка

проход вверх по течению · bash ↗

pip install azure-eventhub azure-identity
# For checkpointing with blob storage
pip install azure-eventhub-checkpointstoreblob-aio

Ограничения и проверки качества

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

Начните с безопасного пробного периода.

Проверьте поддерживаемый хост и инструкции по установке репозитория. Храните каталог Skill, а также связанные с ним скрипты, ресурсы и документацию вместе;SKILL.mdВ одиночку можно опустить зависимости.
Предоставьте агенту ваши реальные входные данные, желаемый результат и критерии приемки. Синтаксис вызова и доступные инструменты зависят от хоста; данный сайт не предполагает универсальной команды установки.
Попробуйте запустить исходный рабочий процесс в тестовом проекте или в его копии. Перед тем как разрешить операции, изменяющие файлы, удаленные сервисы или оплачиваемые ресурсы, проверьте их.
Проверьте выходные данные на соответствие исходным проверкам качества и вашим собственным требованиям. Успешный запуск или большое количество звезд в репозитории не гарантируют корректного результата.

Формат навыков и спецификация каталога ↗

Подробнее читайте в источнике.

Перевод и сфера применения

В этом руководстве по чтению представлены избранные отрывки из закрепленного текста выше по течению.SKILL.mdПеревод выполнен с помощью переводчика. Это не полное руководство и не гарантия проверенной совместимости. Перед использованием ознакомьтесь с оригиналом и указанными в нем файлами.

Данное введение относится к закрепленной ниже версии; текущая активность в репозитории и время сбора данных отображаются отдельно.

Закрепленный источник: Прочитайте оригинал ↗
Источник получен: 2026-10-29T09:32:23Z
Исходный коммит: 00d66a64919edca5bca2c673373444e36a4b5461
Исходный SHA-256: fd26cd3d54d9e92d3d8989b0c2be8f54ab140f41837ba1f4a03da40659f64d03

Вернуться к полному каталогу навыков