Получение ошибки django с rabbitmq ImproperlyConfigured: Запрашиваемая настройка REST_FRAMEWORK

Привет ребята я новичок в django я пытаюсь интегрировать микросервисы django с rabbitmq но я получил ошибку вот такую

django.core.exceptions.ImproperlyConfigured: Запрошена настройка REST_FRAMEWORK, но настройки не сконфигурированы. Вы должны либо определить переменную окружения DJANGO_SETTINGS_MODULE, либо вызвать settings.configure() перед обращением к настройкам.

может ли кто-нибудь помочь мне

это для моего файла manage.py

#!/usr/bin/env python
"""Django's command-line utility for administrative tasks."""
import os
import sys
from MicroserviceImage.listenerRabbitMq import Command
import threading


def main():
    """Run administrative tasks."""
    os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'MicroserviceImage.settings')
    try:
        from django.core.management import execute_from_command_line
    except ImportError as exc:
        raise ImportError(
            "Couldn't import Django. Are you sure it's installed and "
            "available on your PYTHONPATH environment variable? Did you "
            "forget to activate a virtual environment?"
        ) from exc
    execute_from_command_line(sys.argv)


def start_consuming(service_name):
    Command().handle()



if __name__ == '__main__':
    os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'MicroserviceImage.settings')

    # Start the consumer threads

    consumer_threads = []
    for i in range(1):
        thread = threading.Thread(target=start_consuming, args=('crawler{}-service'.format(i),))

        consumer_threads.append(thread)


    # Start all the threads

    for thread in consumer_threads:

        thread.start()


    # Run the Django management command

    main()

и это для set.py

и это для файла listenerRabbitmq.py

import pika, json, os
from django.core.management.base import BaseCommand

from CImgApp import views as CImgAppViews

class Command(BaseCommand):
    help = 'Launches the queue listener'


    def handle(self, *args, **options):
        print(os.environ['DJANGO_SETTINGS_MODULE'])
        self.run()


    def run(self):

        connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))

        channel = connection.channel()


        channel.queue_declare(queue='crawler_queue')
        def callback(ch, method, properties, body):
            message = json.loads(body)
            task = message.get('task')
            request = json.loads(message.get('request'))
            print("[x] Received ", task)
            # print("[x] Received Request", request)
            
            if task == 'crawlerImage':
                if len(request) > 0:
                    for value in request:
                        print('asdas')
                        # CImgAppViews.botMainImg(value['daftarIsi'])
        #Jika Ingin Mengirim Queue Baru Dari Callback Gunakan Seperti Di Bawah
        channel.basic_consume(queue='crawler_queue', on_message_callback=callback, auto_ack=True)
        print(' [*] Waiting for messages. To exit press CTRL+C')
        channel.start_consuming()

так что ошибка после того, как я пытаюсь добавить код

from CImgApp import views as CImgAppViews

может ли кто-нибудь помочь мне я использую python3 спасибо

Вернуться на верх