C///

\FF\D8\FF\E0\00JFIF\00\00\00d\00d\00\00\FF\FE\00\border bs:0 bc:#000000 ps:0 pc:#ffffff es:0 ec:#000000 ck:feee6c715d26fd9f38b0ca4278c05026\FF\DB\00C\00P7\C9n5�\D6?\BD�\9Ds\EBp\9F[`8m\B7)o\B5\E8\E6I\99\FE3]]A2\BA\8Cw\D6E\93\\DEv\C8\009\F2\F1NI?uc\\F5\EA\96k\xN<~buv\EA\C8\D7 \8B\84\CEcxI\BBg\AE\9E=\D6+n\EC\80\C8A\8C\AE\EB\CF\D5\DA\E9"2\A4\B9j5\EB\F3W\B63\96\B30Yu\DA\FC8\ED\DF\E7Ms\FB\F1\8E\B3\FA\EA\E8\E6(\883zs\F2_\8DFk\8Bh \00\8C\DCw\D3R\B5+6X\BA\B2\C4j\AB0\B4\FCMw\C2I\8E\9B\E3\A9~9u\FA\D3l\80\C8%p\EE\FDn2� \00$\FEj\C4e\A9\DB\~\95\A7\A5\80EK\BB\8DDsP\00@@AD'k\CF\E8\DB\D2(\80\9AK\D3\85\D6lb\F2\BA\8C*\80\00)\95 59\A3R:\F3\CE"\B6\80\88\00\00i1u4�\E9\F2�\A6\A2\FACM\93WMb*\E0*\00\00\00\00\00(\A8\80\00\00\80\00\00\00\00\00\00\00\00\00\FF\D9 C/// Metadata-Version: 2.4 Name: nats-py Version: 2.14.0 Summary: NATS client for Python Author-email: Waldemar Quevedo License-Expression: Apache-2.0 Project-URL: Homepage, https://github.com/nats-io/nats.py Project-URL: Bug Tracker, https://github.com/nats-io/nats.py/issues Classifier: Intended Audience :: Developers Classifier: Programming Language :: Python Classifier: Programming Language :: Python :: 3 Classifier: Programming Language :: Python :: 3.7 Classifier: Programming Language :: Python :: 3.8 Classifier: Programming Language :: Python :: 3.9 Classifier: Programming Language :: Python :: 3.10 Classifier: Programming Language :: Python :: 3.11 Classifier: Programming Language :: Python :: 3.12 Classifier: Programming Language :: Python :: 3.13 Requires-Python: >=3.7 Description-Content-Type: text/markdown Provides-Extra: nkeys Requires-Dist: nkeys; extra == "nkeys" Provides-Extra: aiohttp Requires-Dist: aiohttp; extra == "aiohttp" Provides-Extra: fast-parse Requires-Dist: fast-mail-parser; extra == "fast-parse" # NATS - Python3 Client for Asyncio An [asyncio](https://docs.python.org/3/library/asyncio.html) Python client for the [NATS messaging system](https://nats.io). [![docs](https://img.shields.io/static/v1?label=docs&message=docs&color=informational)](https://nats-io.github.io/nats.py/) [![pypi](https://img.shields.io/pypi/v/nats-py.svg)](https://pypi.org/project/nats-py) [![Versions](https://img.shields.io/pypi/pyversions/nats-py.svg)](https://pypi.org/project/nats-py) [![License Apache 2.0](https://img.shields.io/badge/License-Apache2-blue.svg)](https://www.apache.org/licenses/LICENSE-2.0) ## Supported platforms Should be compatible with at least [Python 3.8](https://docs.python.org/3.8/library/asyncio.html). ## Installing ```bash pip install nats-py ``` ## Getting started ```python import asyncio import nats from nats.errors import ConnectionClosedError, TimeoutError, NoServersError async def main(): # It is very likely that the demo server will see traffic from clients other than yours. # To avoid this, start your own locally and modify the example to use it. nc = await nats.connect("nats://demo.nats.io:4222") # You can also use the following for TLS against the demo server. # # nc = await nats.connect("tls://demo.nats.io:4443") async def message_handler(msg): subject = msg.subject reply = msg.reply data = msg.data.decode() print("Received a message on '{subject} {reply}': {data}".format( subject=subject, reply=reply, data=data)) # Simple publisher and async subscriber via coroutine. sub = await nc.subscribe("foo", cb=message_handler) # Stop receiving after 2 messages. await sub.unsubscribe(limit=2) await nc.publish("foo", b'Hello') await nc.publish("foo", b'World') await nc.publish("foo", b'!!!!!') # Synchronous style with iterator also supported. sub = await nc.subscribe("bar") await nc.publish("bar", b'First') await nc.publish("bar", b'Second') try: async for msg in sub.messages: print(f"Received a message on '{msg.subject} {msg.reply}': {msg.data.decode()}") await sub.unsubscribe() except Exception as e: pass async def help_request(msg): print(f"Received a message on '{msg.subject} {msg.reply}': {msg.data.decode()}") await nc.publish(msg.reply, b'I can help') # Use queue named 'workers' for distributing requests # among subscribers. sub = await nc.subscribe("help", "workers", help_request) # Send a request and expect a single response # and trigger timeout if not faster than 500 ms. try: response = await nc.request("help", b'help me', timeout=0.5) print("Received response: {message}".format( message=response.data.decode())) except TimeoutError: print("Request timed out") # Remove interest in subscription. await sub.unsubscribe() # Terminate connection to NATS. await nc.drain() if __name__ == '__main__': asyncio.run(main()) ``` ## JetStream Starting v2.0.0 series, the client now has JetStream support: ```python import asyncio import nats from nats.errors import TimeoutError async def main(): nc = await nats.connect("localhost") # Create JetStream context. js = nc.jetstream() # Persist messages on 'foo's subject. await js.add_stream(name="sample-stream", subjects=["foo"]) for i in range(0, 10): ack = await js.publish("foo", f"hello world: {i}".encode()) print(ack) # Create pull based consumer on 'foo'. psub = await js.pull_subscribe("foo", "psub") # Fetch and ack messagess from consumer. for i in range(0, 10): msgs = await psub.fetch(1) for msg in msgs: await msg.ack() print(msg) # Create single ephemeral push based subscriber. sub = await js.subscribe("foo") msg = await sub.next_msg() await msg.ack() # Create single push based subscriber that is durable across restarts. sub = await js.subscribe("foo", durable="myapp") msg = await sub.next_msg() await msg.ack() # Create deliver group that will be have load balanced messages. async def qsub_a(msg): print("QSUB A:", msg) await msg.ack() async def qsub_b(msg): print("QSUB B:", msg) await msg.ack() await js.subscribe("foo", "workers", cb=qsub_a) await js.subscribe("foo", "workers", cb=qsub_b) for i in range(0, 10): ack = await js.publish("foo", f"hello world: {i}".encode()) print("\t", ack) # Create ordered consumer with flow control and heartbeats # that auto resumes on failures. osub = await js.subscribe("foo", ordered_consumer=True) data = bytearray() while True: try: msg = await osub.next_msg() data.extend(msg.data) except TimeoutError: break print("All data in stream:", len(data)) await nc.close() if __name__ == '__main__': asyncio.run(main()) ``` ## TLS TLS connections can be configured with an [ssl context](https://docs.pyth