Django Генерация Excel и сохранение в виде объекта с помощью Celery и RabbitMQ

Я использую Django 2.2.5, Celery 5.2.6 и RabbitMQ и я новичок в последней версии 2.

Я хочу сгенерировать лист Excel и сохранить его в поле FileField внутри вновь созданного объекта (не загружать его), и вот что я сделал:

project/settings.py:

CELERY_RESULT_BACKEND = "django-db"
CELERY_CACHE_BACKEND = "django-cache"
CELERY_BROKER_URL = "amqp://localhost"

CELERY_ACCEPT_CONTENT = ["application/json"]
CELERY_TASK_SERIALIZER = "json"
CELERY_RESULT_SERIALIZER = "json"
CELERY_TIMEZONE = "Africa/Casablanca"

project/celery.py:

from __future__ import absolute_import, unicode_literals

import os
from celery import Celery

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "verautonoapi.settings")

app = Celery("verautonoapi")

app.config_from_object("django.conf:settings", namespace="CELERY")
app.autodiscover_tasks()


@app.task(bind=True)
def debug_task(self):
    print("Request: {0!r}".format(self.request))

project/init.py :

from __future__ import absolute_import, unicode_literals

# This will make sure the app is always imported when
# Django starts so that shared_task will use this app.
from .celery import app as celery_app

__all__ = ("celery_app",)

app/tasks.py:

from __future__ import absolute_import, unicode_literals
from django.http import HttpResponse, FileResponse
from celery import shared_task
from celery.utils.log import get_task_logger
from time import sleep

from openpyxl import Workbook
from datetime import date
from .models import Dossier, Export

logger = get_task_logger(__name__)


@shared_task(bind=True, track_started=True)
def exp_en_cours(request):
    print("task activated")
    sleep(7)
    print("now starting generating the file")
    dossier_queryset = Dossier.objects.filter(status_admin="Validation OR Requise")
    today = str(date.today())
    response = FileResponse(
        content_type="application/vnd.openxmlformats-officedocument.spreadsheetml.sheet",
    )
    response["Content-Disposition"] = (
        "attachment; filename=" + today + "-dossiers_en_cours.xlsx"
    )
    workbook = Workbook()

    # Get active worksheet/tab
    worksheet = workbook.active
    worksheet.title = "Dossiers en cours"

    # Define the titles for columns
    columns = [
        "Numéro",
        "Créé le",
        "Assurance",
        "Prestataire",
        "Matricule",
    ]

    row_num = 1

    # Assign the titles for each cell of the header
    for col_num, column_title in enumerate(columns, 1):
        cell = worksheet.cell(row=row_num, column=col_num)
        cell.value = column_title

    # Iterate through all movies
    for dossier in dossier_queryset:
        row_num += 1

        # Define the data for each cell in the row
        row = [
            dossier.numero,
            str(dossier.date_posted)[:10],
            dossier.assurance.name,
            dossier.created_by.user.username,
            dossier.matricule,
        ]

        # Assign the data for each cell of the row
        for col_num, cell_value in enumerate(row, 1):
            cell = worksheet.cell(row=row_num, column=col_num)
            cell.value = cell_value

    workbook.save(response)

    Export.objects.create(status="Dossier en cours", file=response)

    return "OK"

app/models.py:

class Export(models.Model):
    STATUS = [
        ("Dossier en cours", "Dossier en cours"),
        ("Dossier validés", "Dossier validés"),
        ("Dossier rejetés", "Dossier rejetés"),
        ("Dossier à clôturer", "Dossier à clôturer"),
        ("Dossier clôturés", "Dossier clôturés"),
        ("Dossier facturés", "Dossier facturés"),
        ("Dossier archivés", "Dossier archivés"),
    ]
    status = models.CharField(max_length=20, choices=STATUS, null=True, blank=True)
    timestamp = models.DateTimeField(auto_now_add=True, editable=False)
    file = models.FileField(
        upload_to=get_rapport_filename, verbose_name="Fichiers Excel"
    )

    def __str__(self):
        return "%s - %s" % (self.dossier, self.timestamp)

    class Meta:
        verbose_name = "Rapport Excel"
        verbose_name_plural = "Rapports Excel"

Я также установил django_celery_results и добавил его в установленные приложения.

Когда я выполняю задание, оно выдает следующую ошибку:

This FileResponse instance is not writable

enter image description here

Я пробовал и на Windows, и на Linux (на digitalocean) и получаю ту же ошибку. Подскажите, что я делаю не так? Функция excel не верна? Потому что я внес в нее изменение, чтобы она не загружалась (заменил HttpResponse на FileResponse). Или это RabbitMQ и Celery?

Вот решение:

from io import BytesIO
from django.core.files.base import ContentFile

vworkbook = BytesIO()
workbook.save(vworkbook)

content = vworkbook.getvalue()

try:
    Export.objects.create(
        status="Dossiers archivés",
        file=ContentFile(
            content, name="dossiers_archivés-" + str(date.today()) + ".xlsx"
        ),
    )
    return "EXP_ARCH OK"
except Exception:
    raise Exception
Вернуться на верх