文件名称:aiozmq:Asyncio(PEP 3156)与ZeroMQ集成
文件大小:119KB
文件格式:ZIP
更新时间:2024-05-24 08:32:27
zeromq asyncio zmq Python
与ZeroMQ异步集成 asyncio(PEP 3156)对ZeroMQ的支持。 aiozmq和香草pyzmq ( zmq.asyncio )之间的区别。 zmq.asyncio仅通过使用自定义事件替换事件循环来工作。 这种方法有效,但有两个缺点: zmq.asyncio.ZMQEventLoop不能与其他循环实现结合使用(最值得注意的是超快速uvloop )。 它使用内部ZMQ Poller,该ZMQ Poller具有对ZMQ套接字的快速支持,但并不打算与许多(数千个)常规TCP套接字一起快速工作。 在实践中这意味着zmq.asyncio不建议与Web服务器等使用aiohttp 。 另见 文献资料 见 简单的高级客户端-服务器RPC示例: import asyncio import aiozmq . rpc class ServerHandler ( aiozmq . r
【文件预览】:
aiozmq-master
----setup.py(2KB)
----.gitignore(88B)
----requirements.txt(184B)
----Makefile(889B)
----MANIFEST.in(88B)
----LICENSE(1KB)
----setup.cfg(96B)
----ACKS.txt(250B)
----.github()
--------workflows()
----requirements-bench.txt(79B)
----examples()
--------stream_monitor.py(919B)
--------socket_event_monitor.py(3KB)
--------rpc_incorrect_calls.py(1KB)
--------rpc_dict_handler.py(704B)
--------rpc_pubsub.py(1KB)
--------rpc_with_subhandlers.py(1KB)
--------sync_async.py(3KB)
--------rpc_pipeline.py(929B)
--------stream_dealer_router.py(619B)
--------rpc_exception_translator.py(858B)
--------core_dealer_router.py(2KB)
--------rpc_custom_translator.py(1KB)
--------rpc_simple.py(648B)
--------rpc_dynamic.py(1KB)
----README.rst(3KB)
----tests()
--------ssl_key.pem(916B)
--------pycacert.pem(4KB)
--------ssl_cert.pem(867B)
--------sample.key(887B)
--------transport_test.py(28KB)
--------zmq_stream_test.py(16KB)
--------rpc_pipeline_test.py(8KB)
--------monitor_test.py(5KB)
--------policy_test.py(5KB)
--------rpc_func_annotations.py(7KB)
--------rpc_test.py(23KB)
--------rpc_namespace_test.py(3KB)
--------sample.crt(822B)
--------rpc_packer_test.py(6KB)
--------echo3.py(240B)
--------echo.py(110B)
--------echo2.py(127B)
--------keycert3.pem(4KB)
--------version_test.py(944B)
--------selectors_test.py(14KB)
--------rpc_translators_test.py(2KB)
--------zmq_events_test.py(28KB)
--------interface_test.py(3KB)
--------rpc_pubsub_test.py(12KB)
----CHANGES.txt(3KB)
----benchmarks()
--------simple.py(11KB)
----.coveragerc(35B)
----runtests.py(10KB)
----docs()
--------core.rst(21KB)
--------Makefile(6KB)
--------spelling_wordlist.txt(0B)
--------examples.rst(2KB)
--------index.rst(4KB)
--------conf.py(7KB)
--------_static()
--------make.bat(5KB)
--------stream.rst(7KB)
--------rpc.rst(30KB)
--------glossary.rst(2KB)
----aiozmq()
--------stream.py(9KB)
--------interface.py(8KB)
--------__init__.py(2KB)
--------cli()
--------log.py(57B)
--------selector.py(6KB)
--------util.py(488B)
--------_test_util.py(10KB)
--------rpc()
--------core.py(30KB)