Skip to main content

A service-activator component for eventstore

Project description

Build Status

atomicpuppy

A service-activator component for eventstore, written in Python

A Brief and Mostly Useless Quickstart:

# config.yaml
atomicpuppy:
    host: localhost
    port: 2113
    # each stream will be polled by a separate async http client
    streams:
        - stream_a
        - stream_b
        - stream_with_a_#date#
    # the counter keeps track of which messages have been processed
    counter:
        redis:
            host: localhost
            port: 6379
# main.py
# AtomicPuppy uses asyncio coroutines for concurrent IO
import asyncio
import logging
import signal
from atomicpuppy import AtomicPuppy

# AtomicPuppy needs a callback to pass you messages.
def handle(msg):
  print(msg)

# Config is read from yaml files.
ap = AtomicPuppy('config.yaml', handle)
loop = asyncio.get_event_loop()

# to kill the puppy, call stop()
def stop():
    logging.debug("SIGINT received, shutting down")
    ap.stop()

loop.add_signal_handler(signal.SIGINT, stop)

# and to start it call start.
loop.run_until_complete(ap.start())

Run the tests

A tox.ini file is provided to run the tests with different versions of Python.

To run the tests:

  1. Make sure you have the Python 3.6, 3.7, 3,8, 3.9 and 3.10 headers installed (for Ubuntu please refer to https://launchpad.net/~deadsnakes/+archive/ubuntu/ppa)
  2. pip install -r test-requirements.txt from the root folder of the repository
  3. Run tox from the root folder of the repository

Prepare and run the tests on Mac with pyenv

Install pyenv and pyenv-virtualenv and python versions

brew install pyenv pyenv-virtualenv

Add the following lines to your .zshrc (check latest pyenv doc):

export PYENV_ROOT="$HOME/.pyenv"
export PATH="$PYENV_ROOT/bin:$PATH"
eval "$(pyenv init --path)"
eval "$(pyenv init -)"
eval "$(pyenv virtualenv-init -)"
pyenv install 3.6.15
pyenv install 3.7.12
pyenv install 3.8.12
pyenv install 3.9.9
pyenv install 3.10.1

Check the latest versions, install the latest minor from each major version.

Create a virtual environment

pyenv virtualenv 3.10.1 atomicpuppy
pyenv activate atomicpuppy
pip install tox-pyenv
pip install -r test-requirements.txt

Run the tests

pyenv local atomicpuppy 3.6.13 3.7.10 3.8.10 3.9.5

tox

About python version

There is a bug in asyncio for python3.4 that was fixed in other versions. This is the bug report: https://bugs.python.org/issue23812 Because of that we have dropped support for python3.4 and we recommend to use python3.7.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

AtomicPuppy-1.5.2.4.tar.gz (39.5 kB view details)

Uploaded Source

Built Distribution

AtomicPuppy-1.5.2.4-py3-none-any.whl (28.0 kB view details)

Uploaded Python 3

File details

Details for the file AtomicPuppy-1.5.2.4.tar.gz.

File metadata

  • Download URL: AtomicPuppy-1.5.2.4.tar.gz
  • Upload date:
  • Size: 39.5 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/4.0.1 CPython/3.9.13

File hashes

Hashes for AtomicPuppy-1.5.2.4.tar.gz
Algorithm Hash digest
SHA256 d00b90384c01c82f5219413bedfc523d86f0908f6115894d3f61be6c7176656c
MD5 73d191b13b2218e9cdce7c9b270c49dd
BLAKE2b-256 7d676c850b74d9e1d6906df39364445fa8e3216036bfc50b1ff70bd84c27b005

See more details on using hashes here.

File details

Details for the file AtomicPuppy-1.5.2.4-py3-none-any.whl.

File metadata

File hashes

Hashes for AtomicPuppy-1.5.2.4-py3-none-any.whl
Algorithm Hash digest
SHA256 b5579d7cb129aff12d62fdd57bf4c3dc2d063b13c93cbaecf6d3ad4a216e9111
MD5 77d3f5a37502d6cf75bbd6eea57d0bec
BLAKE2b-256 55593ce13d1d2602abfacb146fa0c6ffa90b1757e2b347ddc1a8187071c4ce35

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page