simple_eventconsumer's Introduction

Simple Eventconsumer

This is the simplest python event consumer using eventstore I could think of.

Requirements:

docker-compose (and docker of course)

How to Run?

In a terminal run docker-compose up
Once it's running, in another terminal, run:

python send_test_event.py "Gil"

You should see in the docker-compose logs the following:

eventconsumer_1  | WARNING:root:Hi Gil

simple_eventconsumer's People

Contributors

Stargazers

Watchers

simple_eventconsumer's Issues

Dependabot couldn't authenticate with https://pypi.python.org/simple/

Dependabot couldn't authenticate with https://pypi.python.org/simple/.

You can provide authentication details in your Dependabot dashboard by clicking into the account menu (in the top right) and selecting 'Config variables'.

View the update logs.

Dependabot couldn't authenticate with https://pypi.python.org/simple/

Dependabot couldn't authenticate with https://pypi.python.org/simple/.

You can provide authentication details in your Dependabot dashboard by clicking into the account menu (in the top right) and selecting 'Config variables'.

View the update logs.

Client needs to see at least one event when it starts up

If you see this message:

eventconsumer_1  | Traceback (most recent call last):
eventconsumer_1  |   File "/usr/lib/python3.6/site-packages/atomicpuppy/atomicpuppy.py", line 453, in fetch
eventconsumer_1  |     async with self.session.get(uri, params=params, headers=headers) as response:
eventconsumer_1  |   File "/usr/lib/python3.6/site-packages/aiohttp/client.py", line 783, in __aenter__
eventconsumer_1  |     self._resp = await self._coro
eventconsumer_1  |   File "/usr/lib/python3.6/site-packages/aiohttp/client.py", line 412, in _request
eventconsumer_1  |     resp.raise_for_status()
eventconsumer_1  |   File "/usr/lib/python3.6/site-packages/aiohttp/client_reqrep.py", line 789, in raise_for_status
eventconsumer_1  |     headers=self.headers)
eventconsumer_1  | aiohttp.client_exceptions.ClientResponseError: 404, message='Not Found'
eventconsumer_1  | Received bad http response with status 404 from http://eventstore:2113/streams/hello/0/forward/20
eventconsumer_1  | Traceback (most recent call last):
eventconsumer_1  |   File "/usr/lib/python3.6/site-packages/atomicpuppy/atomicpuppy.py", line 453, in fetch
eventconsumer_1  |     async with self.session.get(uri, params=params, headers=headers) as response:
eventconsumer_1  |   File "/usr/lib/python3.6/site-packages/aiohttp/client.py", line 783, in __aenter__
eventconsumer_1  |     self._resp = await self._coro
eventconsumer_1  |   File "/usr/lib/python3.6/site-packages/aiohttp/client.py", line 412, in _request
eventconsumer_1  |     resp.raise_for_status()
eventconsumer_1  |   File "/usr/lib/python3.6/site-packages/aiohttp/client_reqrep.py", line 789, in raise_for_status
eventconsumer_1  |     headers=self.headers)
eventconsumer_1  | aiohttp.client_exceptions.ClientResponseError: 404, message='Not Found'
eventconsumer_1  |
eventconsumer_1  | During handling of the above exception, another exception occurred:

That's because atomicpuppy needs to read one event from the stream, so one way to fix this at this moment is to: