Skip to main content

Django app yang digunakan untuk mempermudah penggunaan rabbit mq

Project description

merupakan package khusus django untuk keperluan berkomunikasi dengan rabbitmq

Quick start

  1. Tambahkan “aiga_amqp” ke INSTALLED_APPS pada file settings.py:

    INSTALLED_APPS = [
        ...
        'aiga_amqp',
    ]

A.1 Message Sender

Berikut contoh kode untuk mengirim message:

from aiga_amqp.core import send_queue

send_queue('nama channel', message='ini pesan')

A.2 Compete Consumer

Berikut merupakan langkah untuk consume antrian message secara “compete” atau bergantian.

  1. Pada folder app yang anda inginkan, tambahkan file consumer.py

  2. Pada file consumer.py buat function untuk menangani message seperti contoh dibawah ini:

    def consumer(channel, method, properties, body):
        print('saya telah baru saja melakukan sesuatu hal yang penting disini ...')
  3. Pada file apps.py override method ready dan lakukan perintah seperti contoh berikut untuk mengeksekusi consumer.py:

    from django.apps import AppConfig
    
    class ExampleConfig(AppConfig):
        default_auto_field = 'django.db.models.BigAutoField'
        name = 'example'
    
        def ready(self) -> None:
            from aiga_amqp.core import AMQPListener
            from .consumer import consumer
            listener = AMQPListener()
            listener.consume(consumer, channel_name='your channel name')
  1. Jalankan django

B.1 Publish Message

segera

B.2 Subscribe Message

segera

Settings Variable

Terdapat beberapa variable yang bisa digunakan pada settings.py beserta default value nya:

AIGA_AMQP = {
    'HOST' : 'localhost',   //alamat host dari rabbitmq
    'PORT' : 5672,          //port dari rabbitmq
    'CREDENTIAL' : False,   //set menjadi True jika menggunakan USERNAME dan PASSWORD
    'USERNAME' : None,      //username untuk mengakses rabbitmq
    'PASSWORD' : None,      //password untuk mengakses rabbitmq
    'HEARTBEAT' : 600,
    'TIMEOUT' : 300
}

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

aiga-django-amqp-0.0.2.tar.gz (4.6 kB view details)

Uploaded Source

File details

Details for the file aiga-django-amqp-0.0.2.tar.gz.

File metadata

  • Download URL: aiga-django-amqp-0.0.2.tar.gz
  • Upload date:
  • Size: 4.6 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/4.0.2 CPython/3.11.0

File hashes

Hashes for aiga-django-amqp-0.0.2.tar.gz
Algorithm Hash digest
SHA256 bb8a8e79b6bbea21891b18ae78e1006c013b7d994674f18567bab6c6979cd6a6
MD5 d4645f80ceec7ea5fef033874d85b624
BLAKE2b-256 8cb4d37879eb07c6dbaffd8a90ce9caf3466d5bd6b7a4fbc94214f28fe7c1fa0

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page