معرفی شرکت ها

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

توضیحات

A simple, lightweight event pipeline in Python.

ویژگی	مقدار
سیستم عامل	-
نام فایل	ap-topical-0.3.1
نام	ap-topical
نسخه کتابخانه	0.3.1
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	Anna Poulakos
ایمیل نویسنده	anna.poulakos@gmail.com
آدرس صفحه اصلی	https://github.com/annapoulakos/ap-topical
آدرس اینترنتی	https://pypi.org/project/ap-topical/
مجوز	-

# Topical A simple, lightweight event pipeline in Python. ## Installation ```bash pip install ap-topical ``` ## Usage ```python import logging, asyncio import ap.topical logging.basicConfig(level=logging.INFO) logger = logging.getLogger(__name__) @ap.topical.event('start') async def start_handler(payload): """Do stuff here""" await ap.topical.publish('end', payload) @ap.topical.event('start') async def start_auditor(payload): logger.info('auditing start event') @ap.topical.event('end') async def end_handler(payload): """Do stuff here""" async main(): await ap.topical.publish('start', {}) if __name__ == '__main__': asyncio.run(main()) ``` ## Events Events are strings (or other hashable objects) that are published via `ap.topical.publish()`. These are used as both a topic and a specific event. ## Subscribing Callbacks to Events You can subscribe a callback to a given event using `ap.topical.subscribe` as in the following example: ```python async def my_event_handler(payload): ... ap.topical.subscribe('my-event', my_event_handler) ``` Additionally, you can use the handy `@ap.topical.event()` decorator to do this for you automatically: ```python @ap.topical.event('my-event') async def my_event_handler(payload): ... ``` ## Publishing Events Events can be published by providing an event and a payload to pass between event handlers. ```python await ap.topical.publish('my-event', {}) ``` ## Multiple Handlers A given event can have any number of handlers (limited by available compute resources). These will all trigger asynchronously. ```python @ap.topical.event('start') async def start_handler(payload): ... @ap.topical.event('start') async def start_auditor(payload): ... await ap.topical.publish('start', {}) ``` This allows you to create robust graphs of event handlers. ## Future Plans * add unsubscribe functionality * add wildcard event support * add default event payload support * add payload validation via msgspec

نحوه نصب

نصب پکیج whl ap-topical-0.3.1:

pip install ap-topical-0.3.1.whl

نصب پکیج tar.gz ap-topical-0.3.1:

pip install ap-topical-0.3.1.tar.gz