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

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

Distributed Task Queue (development branch)

Add you own metrics to your celery backend

RQ (Redis Queue) integration for Flask applications

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

a little task queue for python

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

Beatserver, a periodic task scheduler for Django 🎵

Django email backend with AWS SES and Celery

Full featured redis cache backend for Django.

A Django app that integrates with Dramatiq.

Redis-backed message queue implementation that can hook into a discord bot written with hikari-lightbulb.

Clearly see and debug your celery cluster in real time!

Asynchronous tasks in Python with Celery + RabbitMQ + Redis

PostgreSQL-based Task Queue for Python

Simple job queues for Python

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

Dagon - An Asynchronous Task Graph Execution Engine

Queuing with django celery and rabbitmq

A fast and reliable background task processing library for Python 3.