المقدمة

تشغيل مهام غير متزامنة في كرفس الفانيليا

import asyncio

from .celeryapp import celeryapp


async def async_task():
    await asyncio.sleep(42)


@celeryapp.task
def regular_task():
    coro = async_task()
    asyncio.run(coro)

• إنها تعمل!
• ببساطة
• لا تبعيات خارجية إضافية

• يتم إنشاء حلقة الأحداث داخل كل عامل.
• لا يوجد تبديل السياق بين تنفيذ coroutines
• في وقت ما ، لا ينفذ العامل أكثر من كوروتين واحد
• لا تتم مشاركة الموارد المشتركة بين المهام
• لوحة مرجعية

دعونا نحاول أصعب؟

import asyncio
import threading

from .celeryapp import celeryapp

celeryapp.loop = asyncio.get_event_loop()
celeryapp.loop_runner = threading.Thread(
    target=celeryapp.loop.run_forever,
    daemon=True,
)
celeryapp.loop_runner.start()

async def async_task():
    await asyncio.sleep(42)


@celeryapp.task
def regular_task():
    coro = async_task()
    asyncio.run_coroutine_threadsafe(
        coro=coro,
        loop=celeryapp.loop,
    )

• لا يزال يعمل
• أكثر أو أقل فعالية
• حتى الموارد تتناوب بين coruteines داخل العامل.
• لا توجد حتى الآن تبعيات خارجية إضافية

• الكرفس لا يعرف أي شيء عن تشغيل الكوروتين
• تفقد السيطرة على تنفيذ المهام
• تفقد السيطرة على الاستثناءات
• لوحة مرجعية

صياغة المشكلة

• يجب أن تعمل
• يجب أن تكون Coroutines قادرة على المنافسة
• يجب مشاركة الموارد بين العديد من الملفات القابلة للتنفيذ
• لا يوجد مرجل
• واجهة برمجة تطبيقات بسيطة يمكن التنبؤ بها

import asyncio

from .celeryapp import celeryapp


@celeryapp.task
async def async_task():
    await asyncio.sleep(42)

ملخص

الميزات لفترة وجيزة

• ذرف المهمة غير المتزامنة
• دعم Corutin في إشارات الكرفس

الخطط

أمثلة

آخر