Displaying 1 to 14 from 14 results

flower - Real-time monitor and web admin for Celery distributed task queue

  •    Python

Flower is a web based tool for monitoring and administrating Celery clusters. Flower API enables to manage the cluster via REST API, call tasks and receive task events in real-time via WebSockets.

Dramatiq - Simple distributed task processing for Python 3.

  •    Python

dramatiq is a distributed task processing library for Python with a focus on simplicity, reliability and performance.

AWS-Utilities - Collection of scripts for interacting with Amazon Web Services

  •    Python

Backup AWS RDS instance logs. Log files that have already been downloaded will not be re-downloaded.

pg-rabbitmq-fdw - PostgreSQL RabbitMQ Foreign Data Wrapper

  •    Python

The general idea is to push any inserted / updated / deleted document in PostgreSQL to RabbitMQ so it can (for example) be indexed in an other system. In that example we only send minimal information about the tag (only the PK). We could imagine more fields in the foreign table, like a data json field. Then in the function where we index the tag, we could image a more complex SQL query that will retrieve a bunch of information and store them in the data field as json.




rejected - rejected is a consumer framework for RabbitMQ

  •    Python

Rejected is a AMQP consumer daemon and message processing framework. It allows for rapid development of message processing consumers by handling all of the core functionality of communicating with RabbitMQ and management of consumer processes. Rejected runs as a master process with multiple consumer configurations that are each run it an isolated process. It has the ability to collect statistical data from the consumer processes and report on it.

PythonRabbitMQAPN - Python结合RabbitMQ实现多线程APN推送

  •    Python

Python结合RabbitMQ实现多线程APN推送

asgi_rabbitmq - RabbitMQ backend for ASGI

  •    Python

RabbitMQ backend for ASGI. ASGI is a standard interface between network protocol servers (particularly web servers) and Python applications (Django Channels), intended to allow handling of multiple common protocol styles (including HTTP, HTTP2, and WebSocket).

tomodachi - Microservice library/framework using Python 3 asyncio with support for HTTP + WebSockets, RabbitMQ / AMQP and AWS SNS+SQS, etc

  •    Python

Tomodachi is a tiny framework designed to build fast microservices listening on HTTP or communicating over event driven message buses like RabbitMQ, AMQP, AWS (Amazon Web Services) SNS+SQS, etc. It's designed to be extendable to make use of any type of transport layer available. tomodachi is still a highly experimental project with an unregular release schedule.


aio-pika - Wrapper for the PIKA for asyncio and humans.

  •    Python

Wrapper for the PIKA for asyncio and humans. See examples and the tutorial in documentation. See another examples and the tutorial in documentation.

slackotron - A plugin extensible Slack bot.

  •    Python

A Slack bot extendable via plugins. Slackotron has its own internal models that are stored in a Berkeley SQLite database (DB). The models include message, user, channel, and response. A message has one user and channel. A channel has many users and messages. A channel can either be a Slack channel or direct-message (DM). A user has many channels and messages. A response has one message, user, and channel.

Google-Assistant-Samsung-Smart-TV-Integration - Use Google Assistant as a remote for your Samsung Smart TV

  •    Python

Use your Google Home device as a remote for your Samsung Smart TV. There is no need for a Logitech Harmony device. If you use a Raspberry Pi to run this script you may want to make it start each time you boot your device. There are several ways how to do it. Here is one.

async-worker - Microframework para escrever consumer assíncronos em python

  •    Python

Nesse exemplo, o handler drain_handler() recebe mensagens de ambas as filas: asgard/counts e asgard/counts/errors. Se o handler lançar alguma exception, a mensagem é automaticamente devolvida para a fila (reject com requeue=True); Se o handler rodar sem erros, a mensagem é automaticamente confirmada (ack).

igcollect - Graphite data collector scripts from InnoGames

  •    Python

This repository is for general-purpose data collector scripts which produce Graphite compatible output developed by InnoGames. We have packages for project specific scripts. Please don't commit them there. The scripts are named with lower-case underscore notation. They include the file extension .py. Not portable ones prefixed by the operating system they are working on.