semvec/pypi-packages huggingface dataset:
wscelery 0.2.0
Real time celery monitoring using websockets
License: MIT
Keywords: celery,websocket,monitoring

=========
WS Celery
=========

.. image:: https://img.shields.io/pypi/v/wscelery.svg
    :target: https://pypi.python.org/pypi/wscelery

.. image:: https://travis-ci.org/johan-sports/wscelery.svg?branch=master
    :target: https://travis-ci.org/johan-sports/wscelery

.. image:: https://readthedocs.org/projects/wscelery/badge/?version=latest
    :target: http://wscelery.readthedocs.io/en/latest/?badge=latest
    :alt: Documentation Status

Real time celery monitoring using websockets. Inspired by `flower <https://github.com/mher/flower>`__.

************
Requirements 
************

* Python >= 3.4

************
Installation
************

PyPI version (recommended): ::

    $ pip install wscelery

Development version: ::

    $ pip install https://github.com/johan-sports/wscelery/zipball/master

*****
Usage
*****

Launch the websocket listener on port 8001: ::

    $ wscelery --port=8001

Or launch from celery: ::

    $ celery wscelery -A proj --address=127.0.0.1 --port=8001

Broker URL and other configuration options can be passed through standard Celery options: ::

    $ celery wscelery -A proj --broker=amqp://guest:guest@localhost:5672//

To see all command options use: ::

    $ wscelery --help

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

Full documentation can be found on `Read The Docs`_.

.. _`Read The Docs`: https://wscelery.readthedocs.io

*******
Caveats
*******

* TLS encryption not (yet) supported

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

If you want to contribute, feel free to submit a PR. Please make sure that the tests pass
(run with ``python setup.py test``). Make sure you add your name to `CONTRIBUTORS`_.

.. _`CONTRIBUTORS`: https://github.com/johan-sports/wscelery/blob/master/CONTRIBUTORS

*******
License
*******

Licensed under MIT. See the LICENSE file in the project root directory.
brokkoly 0.3.1
Brokkoly is a framework for enqueuing messages via HTTP request for celery.
License: MIT
Keywords: celery

========
Brokkoly
========

.. image:: https://travis-ci.org/narusemotoki/brokkoly.svg?branch=master
    :target: https://travis-ci.org/narusemotoki/brokkoly

Brokkoly is a framework for enqueuing messages via HTTP request for celery.

`CHANGELOG <https://github.com/narusemotoki/brokkoly/blob/master/CHANGELOG.rst>`_

Example
=======

tasks.py:
---------

.. code-block:: python

   import brokkoly

   b = brokkoly.Brokkoly('example', 'redis://localhost:6379/0')
   celery = b.celery


   def two_times(text: str) -> dict:
       return {
           'text': text * 2
       }
   
   
   @b.task(two_times)
   def echo(text: str) -> None:
       print(text)

:code:`two_times` works as pre processor. It works before enqueing. It means it can return BadRequest to your client. Brokkoly validate message with typehint. Also you can have extra validation and any other process here.

Run :code:`celery -A tasks worker --loglevel=info`

producer.py:
------------

.. code-block:: python

   import brokkoly

   import tasks  # NOQA

   application = brokkoly.producer()

`producer` is WSGI application. You need to import your `tasks` for put message into queue.

Run with uWSGI :code:`uwsgi --http :8080 --wsgi-file producer.py --enable-threads --thunder-lock --master`

Send Test Message!
------------------

:code:`curl -X POST -d '{"message":{"text": "Hello"}}' http://localhost:8080/example/echo`

1. `producer` receives your request
2. `producer` validates your message having `text` and the type is `str` or not. `text`(str)`  is from typehint of :code:`two_times`
3. `producer` validates `two_times` returned value having `text` and the type is `str` or not. `text`(str)`  is from typehint of :code:`echo`
4. `producer` put message :code:`{"message":{"text":"HelloHello"}}` into queue.
5. `curl` receives response.
6. `Celery` calls :code:`echo`


Extra
=====

preprocessor is optional. if you don't need it, you can:

.. code-block:: python

   @b.task()
   def echo(text: str) -> None:
       print(text)

Also you can give multiple preprocessor:

.. code-block:: python

   @b.task(two_times, two_times)
   def echo(text: str) -> None:
       print(text)
musae 0.0.1
A sample Python project
License: MIT
Keywords: sample setuptools development

A sample Python project
=======================

A sample project that exists as an aid to the `Python Packaging User Guide
<https://packaging.python.org>`_'s `Tutorial on Packaging and Distributing
Projects <https://packaging.python.org/en/latest/distributing.html>`_.

This projects does not aim to cover best practices for Python project
development as a whole. For example, it does not provide guidance or tool
recommendations for version control, documentation, or testing.

----

This is the README file for the project.

The file should use UTF-8 encoding and be written using `reStructuredText
<http://docutils.sourceforge.net/rst.html>`_. It
will be used to generate the project webpage on PyPI and will be displayed as
the project homepage on common code-hosting services, and should be written for
that purpose.

Typical contents for this file would include an overview of the project, basic
usage examples, etc. Generally, including the project changelog in here is not
a good idea, although a simple "What's New" section for the most recent version
may be appropriate.