A Pub/Sub framework implemented in Python
Project description
# pshub
`pshub` is a lightweight Python framework that partially implements Publish/Subscribe messaging paradigm.
It utilizes `asyncio` library to support concurrent requests handling. The Python version that we recommend is 3.5+ .
## Name
The name `pshub` indicates the three main components of this library — Pub, Sub and Hub.
## Usage
You can refer to the three example files under directory `examples/`.
## Cheatsheet
### Rule
#### Example
`{"level": {">=": 1, "<": 10}, "message_body": {"contains": "ERROR"}}`
#### Valid Operators
- `contains`
- `<`
- `<=`
- `>`
- `>=`
- `=`
- `!=`
- `excludes`
### Message
#### Example
`{"level": 2, "message_body": "ERROR occurs"}`
## Caveats
- All messages/rules should be Python `dict` whose keys and values are primitive Python type (int, string, etc.)
- The second parameter of the constructor of `PubProtocol`, `msg_gen`, should has following method:
```python
class MessageGenerator(object):
def next(self, loop):
"""
Return next message
Stop the loop if there's no message to publish.
"""
pass
```
## License
Plumbum - A Pub/Sub framework implemented in Python
Copyright (C) 2016 caizixian, lwher
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License as published
by the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
`pshub` is a lightweight Python framework that partially implements Publish/Subscribe messaging paradigm.
It utilizes `asyncio` library to support concurrent requests handling. The Python version that we recommend is 3.5+ .
## Name
The name `pshub` indicates the three main components of this library — Pub, Sub and Hub.
## Usage
You can refer to the three example files under directory `examples/`.
## Cheatsheet
### Rule
#### Example
`{"level": {">=": 1, "<": 10}, "message_body": {"contains": "ERROR"}}`
#### Valid Operators
- `contains`
- `<`
- `<=`
- `>`
- `>=`
- `=`
- `!=`
- `excludes`
### Message
#### Example
`{"level": 2, "message_body": "ERROR occurs"}`
## Caveats
- All messages/rules should be Python `dict` whose keys and values are primitive Python type (int, string, etc.)
- The second parameter of the constructor of `PubProtocol`, `msg_gen`, should has following method:
```python
class MessageGenerator(object):
def next(self, loop):
"""
Return next message
Stop the loop if there's no message to publish.
"""
pass
```
## License
Plumbum - A Pub/Sub framework implemented in Python
Copyright (C) 2016 caizixian, lwher
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License as published
by the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
pshub-0.0.2.tar.gz
(4.4 kB
view details)
File details
Details for the file pshub-0.0.2.tar.gz
.
File metadata
- Download URL: pshub-0.0.2.tar.gz
- Upload date:
- Size: 4.4 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 4bcb51749002ba0b26a497896b066431391e03dd661ea2d5d9312e94b97d0260 |
|
MD5 | c6620fadc764bd99a709276b59f72016 |
|
BLAKE2b-256 | 3db2d37e2a41e06337c8fa6f7e89beac28828a04911ddc54dbbc45087e6f20f0 |