Sync Laravel queue with Python. Provides an interface for communication between Laravel and Python.

Last update: Oct 01, 2022

Overview

Python Laravel Queue

Queue sync between Python and Laravel using Redis driver. You can process jobs dispatched from Laravel in Python.

NOTE: This package is in beta and only Redis is supported currently. Production usage is not recommended until stable release.

In the 1.0.0 stable version these implementations are planned:

Auto-discovery jobs in both Laravel and Python.
Auto-configuration by reading Laravel config in Python side.
More clean API.
Supporting more queue drivers.

Install

pip install python-laravel-queue

Usage

Listen for jobs on Python:

from python_laravel_queue import Queue as PlQueue
from redis import Redis

r = Redis(host='localhost', port=6379, db=0)
queue_python = PlQueue(r, queue='python')

@queue_python.handler
def handle(data):
    name = data['name'] # job name
    data = data['data'] # job data
    print('TEST: ' + data['a'] + ' ' + data['b'] + ' ' + data['c'])

queue_python.listen()

Sending jobs from Laravel :


$job = new \App\Jobs\TestJob('hi','send to','python');
dispatch($job)->onQueue('python');

Schedule a job to be run in Laravel from Python:

from python_laravel_queue import Queue as PlQueue
from redis import Redis

r = Redis(host='localhost', port=6379, db=0)
queue_laravel = PlQueue(r, queue='laravel')
queue_laravel.push('App\\Jobs\\TestJob', {'a': 'hello', 'b': 'send to', 'c': 'laravel'})

TestJob in Laravel:



namespace App\Jobs;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Log;

class TestJob extends Job implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public $a, $b, $c;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct ($a, $b, $c) {
        $this->a = $a;
        $this->b = $b;
        $this->c = $c;
    }

    public function handle () {
        Log::info('TEST: ' . $this->a . ' '. $this->b . ' ' . $this->c);
    }
}

You need to :listen (or :work) the preferred queue name above to handle data sent from Python in Laravel.

php artisan queue:listen --queue=laravel

Sync Laravel queue with Python. Provides an interface for communication between Laravel and Python.

Related tags

Overview

Python Laravel Queue

Install

Usage

Owner

Sinan Bekar

Dagon - An Asynchronous Task Graph Execution Engine

Beatserver, a periodic task scheduler for Django 🎵

A multiprocessing distributed task queue for Django

Clearly see and debug your celery cluster in real time!

Django database backed celery periodic task scheduler with support for task dependency graph

Accept queue automatically on League of Legends.

Add you own metrics to your celery backend

Full featured redis cache backend for Django.

SAQ (Simple Async Queue) is a simple and performant job queueing framework built on top of asyncio and redis

Flower is a web based tool for monitoring and administrating Celery clusters.

A fully-featured e-commerce application powered by Django

Mr. Queue - A distributed worker task queue in Python using Redis & gevent

RQ (Redis Queue) integration for Flask applications

Django email backend with AWS SES and Celery

Asynchronous serverless task queue with timed leasing of tasks

Py_extract is a simple, light-weight python library to handle some extraction tasks using less lines of code

Distributed Task Queue (development branch)

Queuing with django celery and rabbitmq

Asynchronous tasks in Python with Celery + RabbitMQ + Redis

A simple app that provides django integration for RQ (Redis Queue)