معرفی شرکت ها
eventiq-0.1.4
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشتر
تبلیغات ما
مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.
مشاهده بیشترتوضیحات
Cloud native framework for building event driven applications in Python.
| ویژگی | مقدار |
|---|---|
| سیستم عامل | - |
| نام فایل | eventiq-0.1.4 |
| نام | eventiq |
| نسخه کتابخانه | 0.1.4 |
| نگهدارنده | [] |
| ایمیل نگهدارنده | [] |
| نویسنده | Radzim Kowalow |
| ایمیل نویسنده | radzim.kowalow@performance-media.pl |
| آدرس صفحه اصلی | https://github.com/performancemedia/eventiq |
| آدرس اینترنتی | https://pypi.org/project/eventiq/ |
| مجوز | Apache-2.0 |
<p align="center">
<img src="https://performancemedia.github.io/eventiq/assets/logo.svg" style="width: 250px">
</p>
<p align="center">
<em>Cloud native framework for building event driven applications in Python</em>
</p>
[](https://github.com/PyCQA/bandit)
[](https://github.com/charliermarsh/ruff)
*Note: This package is under active development and is not recommended for production use*
---
Version: 0.1.4
Documentation: https://performancemedia.github.io/eventiq/
Repository: https://github.com/performancemedia/eventiq
---
## About
The package utilizes `pydantic`, `async_timeout` and `python-json-logger` as the only required dependencies.
For messages [Cloud Events](https://cloudevents.io/) format is used.
Service can be run as standalone processes, or included into starlette (e.g. FastAPI) applications.
## Installation
```shell
pip install eventiq
```
## Multiple broker support (in progress)
- Stub (in memory using `asyncio.Queue` for PoC, local development and testing)
- NATS (with JetStream)
- Redis Pub/Sub
- Kafka
- Rabbitmq
- Google Cloud PubSub
- And more coming
## Optional Dependencies
- `cli` - `typer` and `aiorun`
- broker of choice: `nats`, `kafka`, `rabbitmq`, `redis`, `pubsub`
- custom message serializers: `msgpack`, `orjson`
- `prometheus` - Metric exposure via `PrometheusMiddleware`
- `opentelemetry` - tracing support
## Motivation
- [Celery](https://docs.celeryq.dev/en/stable/getting-started/introduction.html)
- [Dramatiq](https://dramatiq.io/)
- [Huey](https://huey.readthedocs.io/en/latest/)
- [arq](https://arq-docs.helpmanual.io/)
However, those libraries don't provide a pub/sub pattern, useful for creating
event driven and loosely coupled systems. Furthermore, the majority of those libraries
do not support `asyncio`. This is why this project was born.
## Basic usage
```python
import asyncio
from eventiq import Service, CloudEvent, Middleware
from eventiq.backends.nats.broker import JetStreamBroker
class SendMessageMiddleware(Middleware):
async def after_broker_connect(self, broker: "Broker") -> None:
print(f"After service start, running with {broker}")
await asyncio.sleep(10)
for i in range(100):
await broker.publish("test.topic", data={"counter": i})
print("Published event(s)")
broker = JetStreamBroker(url="nats://localhost:4222")
broker.add_middleware(SendMessageMiddleware())
service = Service(name="example-service", broker=broker)
@service.subscribe("test.topic")
async def example_run(message: CloudEvent):
print(f"Received Message {message.id} with data: {message.data}")
if __name__ == "__main__":
service.run()
```
## Scaling
Each message is load-balanced (depending on broker) between all service instances with the same `name`.
To scale number of processes you can use containers (docker/k8s), [supervisor](http://supervisord.org/),
or web server like gunicorn.
## Features
- Modern, `asyncio` based python 3.8+ syntax
- Minimal dependencies, only `pydantic`, `async_timeout` and `python-json-logger` are required
- Automatic message parsing based on type annotations (like FastAPI)
- Code hot-reload
- Highly scalable: each service can process hundreds of tasks concurrently,
all messages are load balanced between all instances by default
- Resilient - at least once delivery for all messages by default
- Customizable & pluggable message encoders (json, msgpack, custom)
- Json formatted logger
- Multiple broker support (Nats, Kafka, Rabbitmq, Redis, PubSub, and more coming)
- Easily extensible via Middlewares and Plugins
- Cloud Events standard as base message structure (no more python specific `*args` and `**kwargs` in messages)
- AsyncAPI documentation generation from code
- Twelve factor app approach - stdout logging, configuration through environment variables
- Out-of-the-box integration with Prometheus (metrics) and OpenTelemetry (tracing)
- Application bootstrap via `.yaml` file (see examples/configuration)
نیازمندی
| مقدار | نام |
|---|---|
| >=9.0.4 | aio-pika |
| >=0.8,<1.0 | aiokafka |
| >=2.0,<3.0 | aioredis |
| >=2022.11.1,<2023.0.0 | aiorun |
| >=4.0 | async-timeout |
| >=5.2.0,<6.0 | gcloud-aio-pubsub |
| >=2.2,<3.0 | nats-py |
| >=1.17.0,<2.0.0 | opentelemetry-api |
| >=1.17.0,<2.0.0 | opentelemetry-sdk |
| >=0.38b0,<0.39 | opentelemetry-semantic-conventions |
| >=3.8.7,<4.0 | orjson |
| >=1.2.5,<2.0 | ormsgpack |
| >=0.16.0,<1.0 | prometheus-client |
| >=1.0 | pydantic |
| >=2.0 | python-json-logger |
| >=0.7.0 | typer |
زبان مورد نیاز
| مقدار | نام |
|---|---|
| >=3.8.1,<4.0 | Python |
نحوه نصب
نصب پکیج whl eventiq-0.1.4:
pip install eventiq-0.1.4.whl
نصب پکیج tar.gz eventiq-0.1.4:
pip install eventiq-0.1.4.tar.gz