Индекс низкоуровневого API¶
На этой странице перечислены все низкоуровневые API Asyncio.
Получение цикла событий¶
предпочтительная функция для получения запущенного цикла событий. |
|
Получение экземпляра цикла событий (запущенного или текущего через текущую политику). |
|
Установите цикл событий в качестве текущего с помощью текущей политики. |
|
Создайте новый цикл событий. |
Примеры
Методы циклов событий¶
См. также основной раздел документации о Методы циклов событий.
Жизненный цикл
Выполните Future/Task/awaitable до завершения. |
|
Запустите цикл событий навсегда. |
|
Остановите цикл событий. |
|
Закройте цикл событий. |
|
Возвращает |
|
Возвращает |
|
Закройте асинхронные генераторы. |
Отладка
Включите или отключите режим отладки. |
|
Получение текущего режима отладки. |
Планирование обратных вызовов
Вызовите обратный вызов в ближайшее время. |
|
Потокобезопасный вариант |
|
Вызовите обратный вызов после заданного времени. |
|
Вызовите обратный вызов в заданное время. |
Пул потоков/процессов
|
Запуск привязанной к процессору или другой блокирующей функции в исполнителе |
Установите исполнителя по умолчанию для |
Задачи и будущее
Создайте объект |
|
Запланируйте coroutine как |
|
Установите фабрику, используемую |
|
Получите фабрику, которую |
DNS
|
Асинхронная версия |
|
Асинхронная версия |
Сетевые технологии и IPC
|
Откройте TCP-соединение. |
|
Создайте сервер TCP. |
Открыть соединение с сокетом Unix. |
|
Создайте сервер сокетов Unix. |
|
Заверните пару |
|
Откройте дейтаграммное (UDP) соединение. |
|
|
Отправка файла через транспорт. |
|
Обновление существующего соединения до TLS. |
|
Оберните конец трубы для чтения в пару |
Заверните конец трубы для записи в пару |
Розетки
|
Получение данных от |
|
Получение данных из |
|
Получение дейтаграммы от |
Получение дейтаграммы из |
|
|
Отправьте данные на |
|
Отправка дейтаграммы по каналу |
|
Подключите |
|
Примите соединение |
|
Отправьте файл по каналу |
Начните следить за файловым дескриптором на предмет доступности чтения. |
|
Прекращение наблюдения за файловым дескриптором на предмет доступности чтения. |
|
Начните следить за файловым дескриптором на предмет доступности записи. |
|
Прекратите следить за файловым дескриптором на предмет доступности записи. |
Сигналы Unix
Добавьте обработчик для |
|
Удалите обработчик для |
Подпроцессы
Создать подпроцесс. |
|
Создание подпроцесса из команды оболочки. |
Обработка ошибок
Вызовите обработчик исключений. |
|
Установите новый обработчик исключений. |
|
Получение текущего обработчика исключений. |
|
Реализация обработчика исключений по умолчанию. |
Примеры
Использование
loop.create_connection()
для реализации an echo-client.От
loop.create_connection()
до connect a socket.
Перевозки¶
Все транспорты реализуют следующие методы:
Закройте транспорт. |
|
Возвращает |
|
Запрос информации о транспорте. |
|
Установите новый протокол. |
|
Возвращает текущий протокол. |
Транспорты, которые могут принимать данные (TCP и Unix-соединения, трубы и т.д.). Возвращается из методов типа loop.create_connection()
, loop.create_unix_connection()
, loop.connect_read_pipe()
и т. д:
Читать Транспортировка
Возвращает |
|
Получение паузы. |
|
Получение резюме. |
Транспорты, которые могут отправлять данные (TCP и Unix-соединения, трубы и т.д.). Возвращается из методов типа loop.create_connection()
, loop.create_unix_connection()
, loop.connect_write_pipe()
и т. д:
Пишите транспорты
Запись данных на транспорт. |
|
Запись буферов на транспорт. |
|
Возвращает |
|
Закрытие и отправка EOF после очистки буферизованных данных. |
|
Немедленно закройте транспорт. |
|
Возвращает текущий размер выходного буфера. |
|
Верните отметки высокой и низкой воды для контроля расхода воды. |
|
Установите новые отметки высокой и низкой воды для контроля над расходом воды. |
Транспорты, возвращенные loop.create_datagram_endpoint()
:
Датаграммные транспорты
Отправка данных удаленному аналогу. |
|
Немедленно закройте транспорт. |
Низкоуровневая транспортная абстракция над подпроцессами. Возвращается loop.subprocess_exec()
и loop.subprocess_shell()
:
Транспортировка подпроцессов
Возвращает идентификатор процесса подпроцесса. |
|
Возвращает транспорт для запрошенной коммуникационной трубы (stdin, stdout или stderr). |
|
Возвращает код возврата подпроцесса. |
|
Убейте подпроцесс. |
|
Отправьте сигнал подпроцессу. |
|
Остановите подпроцесс. |
|
Убейте подпроцесс и закройте все трубы. |
Протоколы¶
Классы протоколов могут реализовывать следующие методы обратного вызова:
|
Вызывается при установлении соединения. |
|
Вызывается при потере или закрытии соединения. |
|
Вызывается, когда буфер транспорта переходит отметку высокой воды. |
|
Вызывается, когда буфер транспорта опускается ниже отметки низкого уровня воды. |
Протоколы потоковой передачи (TCP, Unix Sockets, Pipes)
|
Вызывается при получении некоторых данных. |
|
Вызывается при получении EOF. |
Протоколы буферизованной потоковой передачи
|
Вызывается для выделения нового буфера приема. |
|
Вызывается, когда буфер был обновлен полученными данными. |
|
Вызывается при получении EOF. |
Протоколы датаграмм
|
Вызывается при получении дейтаграммы. |
|
Вызывается, когда предыдущая операция отправки или получения вызывает ошибку |
Протоколы подпроцессов
|
Вызывается, когда дочерний процесс записывает данные в свою трубу stdout или stderr. |
|
Вызывается, когда один из каналов, связывающих с дочерним процессом, закрывается. |
|
Вызывается при завершении дочернего процесса. Может вызываться перед методами |
Политика циклов событий¶
Политики - это низкоуровневый механизм для изменения поведения функций типа asyncio.get_event_loop()
. Более подробную информацию см. также в основной части policies section.
Доступ к политикам
Верните текущую политику всего процесса. |
|
Установите новую политику в рамках всего процесса. |
|
Базовый класс для объектов политики. |