edx-event-bus-redis


Nameedx-event-bus-redis JSON
Version 0.5.0 PyPI version JSON
download
home_pagehttps://github.com/openedx/event-bus-redis
SummaryRedis Streams implementation for the Open edX event bus.
upload_time2024-04-04 04:40:59
maintainerNone
docs_urlNone
authoredX
requires_python>=3.8
licenseAGPL 3.0
keywords python edx
VCS
bugtrack_url
requirements No requirements were recorded.
Travis-CI No Travis.
coveralls test coverage
            edx_event_bus_redis
#############################

|pypi-badge| |ci-badge| |codecov-badge| |doc-badge| |pyversions-badge|
|license-badge| |status-badge|

Purpose
*******

Redis Streams implementation for the Open edX event bus.

Overview
********
This package implements an event bus for Open EdX using Redis streams.

The event bus acts as a broker between services publishing events and other services that consume these events.

This package contains both the publishing code, which processes events into
messages to send to the stream, and the consumer code, which polls the stream
using a `while True` loop in order to turn messages back into django signal to
be emitted. This django signal contains event data which can be consumed by the
host application which does the actual event handling.
The actual Redis host is configurable.

The repository works together with the openedx/openedx-events repository to make the fully functional event bus.

Documentation
*************

To use this implementation of the Event Bus with openedx-events, you'll need to ensure that below the following Django settings are set::

    # redis connection url
    # https://redis.readthedocs.io/en/stable/examples/ssl_connection_examples.html#Connecting-to-a-Redis-instance-via-a-URL-string
    EVENT_BUS_REDIS_CONNECTION_URL: redis://:password@localhost:6379/
    EVENT_BUS_TOPIC_PREFIX: dev

    # Required, on the producing side only:
    # https://github.com/openedx/openedx-events/blob/06635f3642cee4020d6787df68bba694bd1233fe/openedx_events/event_bus/__init__.py#L105-L112
    # This will load a producer class which can send events to redis streams.
    EVENT_BUS_PRODUCER: edx_event_bus_redis.create_producer

    # Required, on the consumer side only:
    # https://github.com/openedx/openedx-events/blob/06635f3642cee4020d6787df68bba694bd1233fe/openedx_events/event_bus/__init__.py#L150-L157
    # This will load a consumer class which can consume events from redis streams.
    EVENT_BUS_CONSUMER: edx_event_bus_redis.RedisEventConsumer

Optional settings that are worth considering::

    # If the consumer encounters this many consecutive errors, exit with an error. This is intended to be used in a context where a management system (such as Kubernetes) will relaunch the consumer automatically.
    EVENT_BUS_REDIS_CONSUMER_CONSECUTIVE_ERRORS_LIMIT (defaults to None)

    # How long the consumer should wait for new entries in a stream.
    # As we are running the consumer in a while True loop, changing this setting doesn't make much difference
    # expect for changing number of monitoring messages while waiting for new events.
    # https://redis.io/commands/xread/#blocking-for-data
    EVENT_BUS_REDIS_CONSUMER_POLL_TIMEOUT (defaults to 60 seconds)

    # Limits stream size to approximately this number
    EVENT_BUS_REDIS_STREAM_MAX_LEN (defaults to 10_000)

For manual local testing, see ``Testing locally`` section below.


Getting Started
***************

Developing
==========

One Time Setup
--------------
.. code-block::

  # Clone the repository
  git clone git@github.com:openedx/event-bus-redis.git
  cd event-bus-redis

  # Set up a virtualenv using virtualenvwrapper with the same name as the repo and activate it
  mkvirtualenv -p python3.8 event-bus-redis


Every time you develop something in this repo
---------------------------------------------
.. code-block::

  # Activate the virtualenv
  workon event-bus-redis

  # Grab the latest code
  git checkout main
  git pull

  # Install/update the dev requirements
  make requirements

  # Run the tests and quality checks (to verify the status before you make any changes)
  make validate

  # Make a new branch for your changes
  git checkout -b <your_github_username>/<short_description>

  # Using your favorite editor, edit the code to make your change.
  vim ...

  # Run your new tests
  pytest ./path/to/new/tests

  # Run all the tests and quality checks
  make validate

  # Commit all your changes
  git commit ...
  git push

  # Open a PR and ask for review.

Testing locally
---------------

* Please execute below commands in virtual environment to avoid messing with
  your main python installation.
* Install all dependencies using ``make requirements``
* Run ``make redis-up`` in current directory.
* Run ``make consume_test_event`` to start running a single consumer or ``make multiple_consumer_test_event`` to run two consumers with different consumer names.
* Run ``make produce_test_event`` in a separate terminal to produce a fake event, the consumer should log this event.
* You can also add a fake handler to test emitted signal via consumer. Add below code snippet to ``edx_event_bus_redis/internal/consumer.py``.

.. code-block:: python

  from django.dispatch import receiver
  from openedx_events.content_authoring.signals import XBLOCK_DELETED
  @receiver(XBLOCK_DELETED)
  def deleted_handler(sender, signal, **kwargs):
      print(f"""=======================================  signal: {signal}""")
      print(f"""=======================================  kwargs: {kwargs}""")

Deploying
=========

After setting up required configuration, events are produced using the
``openedx_events.get_producer().send()`` method which needs to be called from
the producing side. For more information, visit this `link`_.

.. _link: https://openedx.atlassian.net/wiki/spaces/AC/pages/3508699151/How+to+start+using+the+Event+Bus#Producing-a-signal

To consume events, openedx_events provides a management command called
``consume_events`` which can be called like so:

.. code-block:: bash

   # consume events from topic xblock-status
   python manage.py consume_events --topic xblock-status --group_id test_group --extra '{"consumer_name": "test_group.c1"}'

   # replay events from specific redis msg id
   python manage.py consume_events --topic xblock-deleted --group_id test_group --extra '{"consumer_name": "test_group.c1", "last_read_msg_id": "1679676448892-0"}'

   # process all messages that were not read by this consumer group.
   python manage.py consume_events -t user-login -g user-activity-service --extra '{"check_backlog": true, "consumer_name": "c1"}'

   # claim messages pending for more than 30 minutes (1,800,000 milliseconds) from other consumers in the group.
   python manage.py consume_events -t user-login -g user-activity-service --extra '{"claim_msgs_older_than": 1800000, "consumer_name": "c1"}'

Note that the ``consumer_name`` in ``--extra`` argument is required for redis
event bus as this name uniquely identifies the consumer in a group and helps
with tracking processed and pending messages.

If required, you can also replay events i.e. process messages from a specific
point in history.

.. code-block:: bash

   # replay events from specific redis msg id
   python manage.py consume_events --signal org.openedx.content_authoring.xblock.deleted.v1 --topic xblock-deleted --group_id test_group --extra '{"consumer_name": "c1", "last_read_msg_id": "1684306039300-0"}'

The redis message id can be found from the producer logs in the host application, example:

.. code-block::

   Message delivered to Redis event bus: topic=dev-xblock-deleted, message_id=ab289110-f47e-11ed-bd90-1c83413013cb, signal=<OpenEdxPublicSignal: org.openedx.content_authoring.xblock.deleted.v1>, redis_msg_id=b'1684306039300-0'

Getting Help
************

Documentation
=============

PLACEHOLDER: Start by going through `the documentation`_.  If you need more help see below.

.. _the documentation: https://docs.openedx.org/projects/event-bus-redis

(TODO: `Set up documentation <https://openedx.atlassian.net/wiki/spaces/DOC/pages/21627535/Publish+Documentation+on+Read+the+Docs>`_)

More Help
=========

If you're having trouble, we have discussion forums at
https://discuss.openedx.org where you can connect with others in the
community.

Our real-time conversations are on Slack. You can request a `Slack
invitation`_, then join our `community Slack workspace`_.

For anything non-trivial, the best path is to open an issue in this
repository with as many details about the issue you are facing as you
can provide.

https://github.com/openedx/event-bus-redis/issues

For more information about these options, see the `Getting Help`_ page.

.. _Slack invitation: https://openedx.org/slack
.. _community Slack workspace: https://openedx.slack.com/
.. _Getting Help: https://openedx.org/getting-help

License
*******

The code in this repository is licensed under the AGPL 3.0 unless
otherwise noted.

Please see `LICENSE.txt <LICENSE.txt>`_ for details.

Contributing
************

Contributions are very welcome.
Please read `How To Contribute <https://openedx.org/r/how-to-contribute>`_ for details.

This project is currently accepting all types of contributions, bug fixes,
security fixes, maintenance work, or new features.  However, please make sure
to have a discussion about your new feature idea with the maintainers prior to
beginning development to maximize the chances of your change being accepted.
You can start a conversation by creating a new issue on this repo summarizing
your idea.

The Open edX Code of Conduct
****************************

All community members are expected to follow the `Open edX Code of Conduct`_.

.. _Open edX Code of Conduct: https://openedx.org/code-of-conduct/

People
******

The assigned maintainers for this component and other project details may be
found in `Backstage`_. Backstage pulls this data from the ``catalog-info.yaml``
file in this repo.

.. _Backstage: https://open-edx-backstage.herokuapp.com/catalog/default/component/event-bus-redis

Reporting Security Issues
*************************

Please do not report security issues in public. Please email security@openedx.org.

.. |pypi-badge| image:: https://img.shields.io/pypi/v/edx-event-bus-redis.svg
    :target: https://pypi.python.org/pypi/edx-event-bus-redis/
    :alt: PyPI

.. |ci-badge| image:: https://github.com/openedx/event-bus-redis/workflows/Python%20CI/badge.svg?branch=main
    :target: https://github.com/openedx/event-bus-redis/actions
    :alt: CI

.. |codecov-badge| image:: https://codecov.io/github/openedx/event-bus-redis/coverage.svg?branch=main
    :target: https://codecov.io/github/openedx/event-bus-redis?branch=main
    :alt: Codecov

.. |doc-badge| image:: https://readthedocs.org/projects/edx-event-bus-redis/badge/?version=latest
    :target: https://event-bus-redis.readthedocs.io/en/latest/
    :alt: Documentation

.. |pyversions-badge| image:: https://img.shields.io/pypi/pyversions/edx-event-bus-redis.svg
    :target: https://pypi.python.org/pypi/event-bus-redis/
    :alt: Supported Python versions

.. |license-badge| image:: https://img.shields.io/github/license/openedx/event-bus-redis.svg
    :target: https://github.com/openedx/event-bus-redis/blob/main/LICENSE.txt
    :alt: License

.. |status-badge| image:: https://img.shields.io/badge/Status-Experimental-yellow


Change Log
##########

..
   All enhancements and patches to edx_event_bus_redis will be documented
   in this file.  It adheres to the structure of https://keepachangelog.com/ ,
   but in reStructuredText instead of Markdown (for ease of incorporation into
   Sphinx documentation and the PyPI description).

   This project adheres to Semantic Versioning (https://semver.org/).

.. There should always be an "Unreleased" section for changes pending release.

Unreleased
**********

*

[0.3.3] - 2023-10-13
************************************************

Added
=====
* Use utility from openedx_events to reset application state before processing
  event

[0.3.2] - 2023-09-01
************************************************

Added
=====
* Adds custom exceptions for producing and consuming errors.

[0.3.1] - 2023-05-24
************************************************

Added
=====

* Option to limit length of stream.

Changed
=======

* Updated README.

[0.3.0] - 2023-05-23
************************************************

Changed
=======
* **BREAKING CHANGE**: Removed deprecated ``signal`` argument from consumer.

[0.2.1] - 2023-05-12
************************************************

Changed
=======
* Deprecated ``signal`` argument in consumer (made optional in preparation for removal)

[0.1.1] - 2023-05-12
************************************************

Added
=====

* Option to claim messages from other consumers based on idle time.

Changed
=======

* Setting ``check_backlog`` will read messages that were not read by this consumer group.

[0.1.0] - 2023-05-04
************************************************

Added
=====

* First release on PyPI.
* Redis streams consumer and producer implemented.

            

Raw data

            {
    "_id": null,
    "home_page": "https://github.com/openedx/event-bus-redis",
    "name": "edx-event-bus-redis",
    "maintainer": null,
    "docs_url": null,
    "requires_python": ">=3.8",
    "maintainer_email": null,
    "keywords": "Python edx",
    "author": "edX",
    "author_email": "oscm@edx.org",
    "download_url": "https://files.pythonhosted.org/packages/34/14/abebc9eec2c1c8cced9bb28ae689341b6fc383dcd2030cefdcefe375a426/edx_event_bus_redis-0.5.0.tar.gz",
    "platform": null,
    "description": "edx_event_bus_redis\n#############################\n\n|pypi-badge| |ci-badge| |codecov-badge| |doc-badge| |pyversions-badge|\n|license-badge| |status-badge|\n\nPurpose\n*******\n\nRedis Streams implementation for the Open edX event bus.\n\nOverview\n********\nThis package implements an event bus for Open EdX using Redis streams.\n\nThe event bus acts as a broker between services publishing events and other services that consume these events.\n\nThis package contains both the publishing code, which processes events into\nmessages to send to the stream, and the consumer code, which polls the stream\nusing a `while True` loop in order to turn messages back into django signal to\nbe emitted. This django signal contains event data which can be consumed by the\nhost application which does the actual event handling.\nThe actual Redis host is configurable.\n\nThe repository works together with the openedx/openedx-events repository to make the fully functional event bus.\n\nDocumentation\n*************\n\nTo use this implementation of the Event Bus with openedx-events, you'll need to ensure that below the following Django settings are set::\n\n    # redis connection url\n    # https://redis.readthedocs.io/en/stable/examples/ssl_connection_examples.html#Connecting-to-a-Redis-instance-via-a-URL-string\n    EVENT_BUS_REDIS_CONNECTION_URL: redis://:password@localhost:6379/\n    EVENT_BUS_TOPIC_PREFIX: dev\n\n    # Required, on the producing side only:\n    # https://github.com/openedx/openedx-events/blob/06635f3642cee4020d6787df68bba694bd1233fe/openedx_events/event_bus/__init__.py#L105-L112\n    # This will load a producer class which can send events to redis streams.\n    EVENT_BUS_PRODUCER: edx_event_bus_redis.create_producer\n\n    # Required, on the consumer side only:\n    # https://github.com/openedx/openedx-events/blob/06635f3642cee4020d6787df68bba694bd1233fe/openedx_events/event_bus/__init__.py#L150-L157\n    # This will load a consumer class which can consume events from redis streams.\n    EVENT_BUS_CONSUMER: edx_event_bus_redis.RedisEventConsumer\n\nOptional settings that are worth considering::\n\n    # If the consumer encounters this many consecutive errors, exit with an error. This is intended to be used in a context where a management system (such as Kubernetes) will relaunch the consumer automatically.\n    EVENT_BUS_REDIS_CONSUMER_CONSECUTIVE_ERRORS_LIMIT (defaults to None)\n\n    # How long the consumer should wait for new entries in a stream.\n    # As we are running the consumer in a while True loop, changing this setting doesn't make much difference\n    # expect for changing number of monitoring messages while waiting for new events.\n    # https://redis.io/commands/xread/#blocking-for-data\n    EVENT_BUS_REDIS_CONSUMER_POLL_TIMEOUT (defaults to 60 seconds)\n\n    # Limits stream size to approximately this number\n    EVENT_BUS_REDIS_STREAM_MAX_LEN (defaults to 10_000)\n\nFor manual local testing, see ``Testing locally`` section below.\n\n\nGetting Started\n***************\n\nDeveloping\n==========\n\nOne Time Setup\n--------------\n.. code-block::\n\n  # Clone the repository\n  git clone git@github.com:openedx/event-bus-redis.git\n  cd event-bus-redis\n\n  # Set up a virtualenv using virtualenvwrapper with the same name as the repo and activate it\n  mkvirtualenv -p python3.8 event-bus-redis\n\n\nEvery time you develop something in this repo\n---------------------------------------------\n.. code-block::\n\n  # Activate the virtualenv\n  workon event-bus-redis\n\n  # Grab the latest code\n  git checkout main\n  git pull\n\n  # Install/update the dev requirements\n  make requirements\n\n  # Run the tests and quality checks (to verify the status before you make any changes)\n  make validate\n\n  # Make a new branch for your changes\n  git checkout -b <your_github_username>/<short_description>\n\n  # Using your favorite editor, edit the code to make your change.\n  vim ...\n\n  # Run your new tests\n  pytest ./path/to/new/tests\n\n  # Run all the tests and quality checks\n  make validate\n\n  # Commit all your changes\n  git commit ...\n  git push\n\n  # Open a PR and ask for review.\n\nTesting locally\n---------------\n\n* Please execute below commands in virtual environment to avoid messing with\n  your main python installation.\n* Install all dependencies using ``make requirements``\n* Run ``make redis-up`` in current directory.\n* Run ``make consume_test_event`` to start running a single consumer or ``make multiple_consumer_test_event`` to run two consumers with different consumer names.\n* Run ``make produce_test_event`` in a separate terminal to produce a fake event, the consumer should log this event.\n* You can also add a fake handler to test emitted signal via consumer. Add below code snippet to ``edx_event_bus_redis/internal/consumer.py``.\n\n.. code-block:: python\n\n  from django.dispatch import receiver\n  from openedx_events.content_authoring.signals import XBLOCK_DELETED\n  @receiver(XBLOCK_DELETED)\n  def deleted_handler(sender, signal, **kwargs):\n      print(f\"\"\"=======================================  signal: {signal}\"\"\")\n      print(f\"\"\"=======================================  kwargs: {kwargs}\"\"\")\n\nDeploying\n=========\n\nAfter setting up required configuration, events are produced using the\n``openedx_events.get_producer().send()`` method which needs to be called from\nthe producing side. For more information, visit this `link`_.\n\n.. _link: https://openedx.atlassian.net/wiki/spaces/AC/pages/3508699151/How+to+start+using+the+Event+Bus#Producing-a-signal\n\nTo consume events, openedx_events provides a management command called\n``consume_events`` which can be called like so:\n\n.. code-block:: bash\n\n   # consume events from topic xblock-status\n   python manage.py consume_events --topic xblock-status --group_id test_group --extra '{\"consumer_name\": \"test_group.c1\"}'\n\n   # replay events from specific redis msg id\n   python manage.py consume_events --topic xblock-deleted --group_id test_group --extra '{\"consumer_name\": \"test_group.c1\", \"last_read_msg_id\": \"1679676448892-0\"}'\n\n   # process all messages that were not read by this consumer group.\n   python manage.py consume_events -t user-login -g user-activity-service --extra '{\"check_backlog\": true, \"consumer_name\": \"c1\"}'\n\n   # claim messages pending for more than 30 minutes (1,800,000 milliseconds) from other consumers in the group.\n   python manage.py consume_events -t user-login -g user-activity-service --extra '{\"claim_msgs_older_than\": 1800000, \"consumer_name\": \"c1\"}'\n\nNote that the ``consumer_name`` in ``--extra`` argument is required for redis\nevent bus as this name uniquely identifies the consumer in a group and helps\nwith tracking processed and pending messages.\n\nIf required, you can also replay events i.e. process messages from a specific\npoint in history.\n\n.. code-block:: bash\n\n   # replay events from specific redis msg id\n   python manage.py consume_events --signal org.openedx.content_authoring.xblock.deleted.v1 --topic xblock-deleted --group_id test_group --extra '{\"consumer_name\": \"c1\", \"last_read_msg_id\": \"1684306039300-0\"}'\n\nThe redis message id can be found from the producer logs in the host application, example:\n\n.. code-block::\n\n   Message delivered to Redis event bus: topic=dev-xblock-deleted, message_id=ab289110-f47e-11ed-bd90-1c83413013cb, signal=<OpenEdxPublicSignal: org.openedx.content_authoring.xblock.deleted.v1>, redis_msg_id=b'1684306039300-0'\n\nGetting Help\n************\n\nDocumentation\n=============\n\nPLACEHOLDER: Start by going through `the documentation`_.  If you need more help see below.\n\n.. _the documentation: https://docs.openedx.org/projects/event-bus-redis\n\n(TODO: `Set up documentation <https://openedx.atlassian.net/wiki/spaces/DOC/pages/21627535/Publish+Documentation+on+Read+the+Docs>`_)\n\nMore Help\n=========\n\nIf you're having trouble, we have discussion forums at\nhttps://discuss.openedx.org where you can connect with others in the\ncommunity.\n\nOur real-time conversations are on Slack. You can request a `Slack\ninvitation`_, then join our `community Slack workspace`_.\n\nFor anything non-trivial, the best path is to open an issue in this\nrepository with as many details about the issue you are facing as you\ncan provide.\n\nhttps://github.com/openedx/event-bus-redis/issues\n\nFor more information about these options, see the `Getting Help`_ page.\n\n.. _Slack invitation: https://openedx.org/slack\n.. _community Slack workspace: https://openedx.slack.com/\n.. _Getting Help: https://openedx.org/getting-help\n\nLicense\n*******\n\nThe code in this repository is licensed under the AGPL 3.0 unless\notherwise noted.\n\nPlease see `LICENSE.txt <LICENSE.txt>`_ for details.\n\nContributing\n************\n\nContributions are very welcome.\nPlease read `How To Contribute <https://openedx.org/r/how-to-contribute>`_ for details.\n\nThis project is currently accepting all types of contributions, bug fixes,\nsecurity fixes, maintenance work, or new features.  However, please make sure\nto have a discussion about your new feature idea with the maintainers prior to\nbeginning development to maximize the chances of your change being accepted.\nYou can start a conversation by creating a new issue on this repo summarizing\nyour idea.\n\nThe Open edX Code of Conduct\n****************************\n\nAll community members are expected to follow the `Open edX Code of Conduct`_.\n\n.. _Open edX Code of Conduct: https://openedx.org/code-of-conduct/\n\nPeople\n******\n\nThe assigned maintainers for this component and other project details may be\nfound in `Backstage`_. Backstage pulls this data from the ``catalog-info.yaml``\nfile in this repo.\n\n.. _Backstage: https://open-edx-backstage.herokuapp.com/catalog/default/component/event-bus-redis\n\nReporting Security Issues\n*************************\n\nPlease do not report security issues in public. Please email security@openedx.org.\n\n.. |pypi-badge| image:: https://img.shields.io/pypi/v/edx-event-bus-redis.svg\n    :target: https://pypi.python.org/pypi/edx-event-bus-redis/\n    :alt: PyPI\n\n.. |ci-badge| image:: https://github.com/openedx/event-bus-redis/workflows/Python%20CI/badge.svg?branch=main\n    :target: https://github.com/openedx/event-bus-redis/actions\n    :alt: CI\n\n.. |codecov-badge| image:: https://codecov.io/github/openedx/event-bus-redis/coverage.svg?branch=main\n    :target: https://codecov.io/github/openedx/event-bus-redis?branch=main\n    :alt: Codecov\n\n.. |doc-badge| image:: https://readthedocs.org/projects/edx-event-bus-redis/badge/?version=latest\n    :target: https://event-bus-redis.readthedocs.io/en/latest/\n    :alt: Documentation\n\n.. |pyversions-badge| image:: https://img.shields.io/pypi/pyversions/edx-event-bus-redis.svg\n    :target: https://pypi.python.org/pypi/event-bus-redis/\n    :alt: Supported Python versions\n\n.. |license-badge| image:: https://img.shields.io/github/license/openedx/event-bus-redis.svg\n    :target: https://github.com/openedx/event-bus-redis/blob/main/LICENSE.txt\n    :alt: License\n\n.. |status-badge| image:: https://img.shields.io/badge/Status-Experimental-yellow\n\n\nChange Log\n##########\n\n..\n   All enhancements and patches to edx_event_bus_redis will be documented\n   in this file.  It adheres to the structure of https://keepachangelog.com/ ,\n   but in reStructuredText instead of Markdown (for ease of incorporation into\n   Sphinx documentation and the PyPI description).\n\n   This project adheres to Semantic Versioning (https://semver.org/).\n\n.. There should always be an \"Unreleased\" section for changes pending release.\n\nUnreleased\n**********\n\n*\n\n[0.3.3] - 2023-10-13\n************************************************\n\nAdded\n=====\n* Use utility from openedx_events to reset application state before processing\n  event\n\n[0.3.2] - 2023-09-01\n************************************************\n\nAdded\n=====\n* Adds custom exceptions for producing and consuming errors.\n\n[0.3.1] - 2023-05-24\n************************************************\n\nAdded\n=====\n\n* Option to limit length of stream.\n\nChanged\n=======\n\n* Updated README.\n\n[0.3.0] - 2023-05-23\n************************************************\n\nChanged\n=======\n* **BREAKING CHANGE**: Removed deprecated ``signal`` argument from consumer.\n\n[0.2.1] - 2023-05-12\n************************************************\n\nChanged\n=======\n* Deprecated ``signal`` argument in consumer (made optional in preparation for removal)\n\n[0.1.1] - 2023-05-12\n************************************************\n\nAdded\n=====\n\n* Option to claim messages from other consumers based on idle time.\n\nChanged\n=======\n\n* Setting ``check_backlog`` will read messages that were not read by this consumer group.\n\n[0.1.0] - 2023-05-04\n************************************************\n\nAdded\n=====\n\n* First release on PyPI.\n* Redis streams consumer and producer implemented.\n",
    "bugtrack_url": null,
    "license": "AGPL 3.0",
    "summary": "Redis Streams implementation for the Open edX event bus.",
    "version": "0.5.0",
    "project_urls": {
        "Homepage": "https://github.com/openedx/event-bus-redis"
    },
    "split_keywords": [
        "python",
        "edx"
    ],
    "urls": [
        {
            "comment_text": "",
            "digests": {
                "blake2b_256": "09f2a232fc138218cebacec9c871ce3cd74bb01bdefc17684c288fbb2801a54b",
                "md5": "9ddba122522e0de7078185f98b83086c",
                "sha256": "179439baaa61a1e05fe289fa8e6799b5c3d1f23f88321da5dc839c88a58d98cd"
            },
            "downloads": -1,
            "filename": "edx_event_bus_redis-0.5.0-py2.py3-none-any.whl",
            "has_sig": false,
            "md5_digest": "9ddba122522e0de7078185f98b83086c",
            "packagetype": "bdist_wheel",
            "python_version": "py2.py3",
            "requires_python": ">=3.8",
            "size": 34573,
            "upload_time": "2024-04-04T04:40:57",
            "upload_time_iso_8601": "2024-04-04T04:40:57.857565Z",
            "url": "https://files.pythonhosted.org/packages/09/f2/a232fc138218cebacec9c871ce3cd74bb01bdefc17684c288fbb2801a54b/edx_event_bus_redis-0.5.0-py2.py3-none-any.whl",
            "yanked": false,
            "yanked_reason": null
        },
        {
            "comment_text": "",
            "digests": {
                "blake2b_256": "3414abebc9eec2c1c8cced9bb28ae689341b6fc383dcd2030cefdcefe375a426",
                "md5": "7361401d0a0860e046ccb46713319422",
                "sha256": "0a8fe5889db79eec3632b0090c6be9fcfe013c7d17ff0ac6bdea2451992691e5"
            },
            "downloads": -1,
            "filename": "edx_event_bus_redis-0.5.0.tar.gz",
            "has_sig": false,
            "md5_digest": "7361401d0a0860e046ccb46713319422",
            "packagetype": "sdist",
            "python_version": "source",
            "requires_python": ">=3.8",
            "size": 37845,
            "upload_time": "2024-04-04T04:40:59",
            "upload_time_iso_8601": "2024-04-04T04:40:59.591021Z",
            "url": "https://files.pythonhosted.org/packages/34/14/abebc9eec2c1c8cced9bb28ae689341b6fc383dcd2030cefdcefe375a426/edx_event_bus_redis-0.5.0.tar.gz",
            "yanked": false,
            "yanked_reason": null
        }
    ],
    "upload_time": "2024-04-04 04:40:59",
    "github": true,
    "gitlab": false,
    "bitbucket": false,
    "codeberg": false,
    "github_user": "openedx",
    "github_project": "event-bus-redis",
    "travis_ci": false,
    "coveralls": true,
    "github_actions": true,
    "tox": true,
    "lcname": "edx-event-bus-redis"
}
        
edX
Elapsed time: 0.22344s