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

Simple job queues for Python

FastAPI with Celery

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

Add you own metrics to your celery backend

Distributed Task Queue (development branch)

Clearly see and debug your celery cluster in real time!

Accept queue automatically on League of Legends.

Distributed Task Queue (development branch)

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

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

Django email backend with AWS SES and Celery

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

Pyramid configuration with celery integration. Allows you to use pyramid .ini files to configure celery and have your pyramid configuration inside celery tasks.

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

OpenQueue is a experimental CS: GO match system written in asyncio python.

A Django app that integrates with Dramatiq.

a little task queue for python

A fully-featured e-commerce application powered by Django

RQ (Redis Queue) integration for Flask applications