repid

KO | EN

gitlite — search

#javascript #go #android #machine-learning #rust #nodejs #cli #kubernetes #vue #awesome-list #security #mcp #openai #open-source

(★ 134)

Repid is a simple, fast, and extensible async task queue framework, with built-in AsyncAPI 3.0 schema generation

File Explorer

Download Latest Version (.zip)

- devcontainer.json
- - bug_report.md
  - feature_request.md
  - other.md
- - codeql.yml
  - dependency-review.yml
  - docs.yml
  - mypy.yml
  - release.yaml
  - tests.yaml
- CODE_OF_CONDUCT.md
- dependabot.yml
- FUNDING.yml
- PULL_REQUEST_TEMPLATE.md
- - your_own_brokers.md
  - your_own_converter.md
  - your_own_serializer.md
- - .gitignore
  - chart.svg
- - chaining_jobs.md
  - large_payloads.md
  - middlewares.md
  - opentelemetry_middleware.md
  - rabbitmq_retries.md
  - sentry_middleware.md
  - testing.md
- - glossary.md
  - quickstart.md
  - supported_brokers.md
- - asyncapi.md
  - fastapi_and_pydantic.md
- - dependency_injection.md
  - message_registry.md
  - messages.md
  - raw_message_and_eager_response.md
  - server_registry.md
  - server_specific_parameters.md
- benchmarks.md
- contributing.md
- features.md
- index.md
- playground.md
- - __init__.py
  - asyncify_.py
  - is_installed.py
  - json_encoder.py
  - not_set.py
- - __init__.py
  - generator.py
- - __init__.py
  - abc.py
- - __init__.py
  - actor.py
  - channel.py
  - contact.py
  - converter_input_schema.py
  - external_docs.py
  - license.py
  - message.py
  - message_schema.py
  - operation.py
  - runner_info.py
  - tag.py
- - __init__.py
  - _utils.py
  - depends.py
  - full_payload.py
  - header_dependency.py
  - message_dependency.py
- __init__.py
- _runner.py
- _worker.py
- asyncapi_server.py
- converter.py
- health_check_server.py
- logger.py
- main.py
- message_registry.py
- middlewares.py
- py.typed
- router.py
- serializer.py
- server_registry.py
- test_client.py
- - __init__.py
  - conftest.py
  - pubsub_proto_helpers.py
  - rabbitmq_definitions.json
  - test_asyncapi_compatibility.py
  - test_default_flow.py
  - test_kafka_specific.py
  - test_nats_specific.py
  - test_rabbitmq_specific.py
  - test_sqs_specific.py
  - test_worker.py
- - __init__.py
  - conftest.py
  - test_asyncapi_generator.py
  - test_channel.py
  - test_converter.py
  - test_dependencies.py
  - test_health_check_server.py
  - test_main.py
  - test_middleware.py
  - test_router.py
  - test_runner.py
  - test_runner_manual_explicit.py
  - test_serializer.py
  - test_server_registry.py
  - test_test_client.py
  - test_utils.py
  - test_worker.py
- __init__.py
.gitignore
.pre-commit-config.yaml
LICENSE
Makefile
mkdocs.yml
pyproject.toml
README.md
SECURITY.md
uv.lock

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# repid

[![PyPI version](https://img.shields.io/pypi/v/repid.svg)](https://pypi.org/project/repid/)
[![Coverage](https://repid.aleksul.space/badges/coverage.svg)](https://github.com/aleksul/repid/actions)
[![Tests](https://github.com/aleksul/repid/actions/workflows/tests.yaml/badge.svg)](https://github.com/aleksul/repid/actions/workflows/tests.yaml)
[![PyPI pyversions](https://img.shields.io/pypi/pyversions/repid.svg)](https://pypi.python.org/pypi/repid/)
[![Read documentation](https://img.shields.io/badge/read-documentation-informational.svg)](https://repid.aleksul.space)

<br>

**Repid** is a simple, fast, and extensible async task queue framework,
with built-in [AsyncAPI 3.0](https://www.asyncapi.com/) schema generation.

<br>

```bash
pip install repid
```

## Features

- **AsyncAPI 3.0 out of the box** - your schema is generated automatically as you build.
  No separate spec files to maintain, no drift between code and docs.

- **Broker flexibility** - works with RabbitMQ, Redis, AWS SQS, Kafka, NATS,
  and Google Cloud Pub/Sub.
  Switch or run multiple brokers side by side without changing your actor code.

- **Extreme performance** - built for maximum throughput and minimal overhead,
  making it the fastest async task queue in the Python ecosystem.

- **Developer ergonomics** - define actors as plain async functions with dependency
  injection and Pydantic argument validation.

- **Built for testability** - a drop-in `TestClient` lets you test actors in-memory
  without a running broker, making unit tests fast and dependency-free.

- **LLM-friendly documentation** - grab `llms.txt` or `llms-full.txt` from the docs site
  to feed into your favorite AI coding assistant.

## Quickstart

Here is how the simplest producer-consumer application looks, using AMQP server.

Producer:

```python
import asyncio

from repid import AmqpServer, Repid

app = Repid(title="My App", version="1.0.0")
app.servers.register_server(
    "default",
    AmqpServer("amqp://user:password@localhost:5672"),
    is_default=True,
)

async def main() -> None:
    async with app.servers.default.connection():
        await app.send_message(
            channel="default",
            payload=b"",
            headers={"topic": "awesome_job"},
        )

asyncio.run(main())
```

Consumer:

```python
import asyncio

from repid import AmqpServer, Repid, Router

app = Repid(title="My App", version="1.0.0")
app.servers.register_server(
    "default",
    AmqpServer("amqp://user:password@localhost:5672"),
    is_default=True,
)

router = Router()

@router.actor
async def awesome_job() -> None:
    print("Hello async jobs!")
    await asyncio.sleep(1.0)

app.include_router(router)

async def main() -> None:
    async with app.servers.default.connection():
        await app.run_worker()

asyncio.run(main())
```

Check out [user guide] to learn more!

## License

**Repid** is distributed under the terms of the MIT license. Please see [License.md] for more information.

**Repid's logo** is distributed under the terms of the [CC BY-NC 4.0] license.
It is originally created by [ari_the_crow_].

[License.md]: https://github.com/aleksul/repid/blob/master/LICENSE
[user guide]: https://repid.aleksul.space
[CC BY-NC 4.0]: https://creativecommons.org/licenses/by-nc/4.0/
[ari_the_crow_]: https://www.instagram.com/p/Cd-ob1NNZ84/

repid

File Explorer

Today's picks

Was this content helpful?

Recent Feedback

repid

File Explorer

Today's picks

Was this content helpful?

Recent Feedback

Download README