परिचय

वेनिला अजवाइन में asyncio कार्य चलाएँ

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)

• यह काम करता हैं!
• केवल
• कोई अतिरिक्त बाहरी निर्भरता नहीं

• ईवेंट लूप प्रत्येक कार्यकर्ता के अंदर बनाया गया है।
• कोरटाइन को निष्पादित करने के बीच कोई संदर्भ स्विच नहीं है
• एक समय में, कार्यकर्ता एक से अधिक कोरटाइन निष्पादित नहीं करता है
• साझा संसाधनों को कार्यों के बीच साझा नहीं किया जाता है
• बॉयलरप्लेट

चलिए ट्रिकियर की कोशिश करते हैं?

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,
    )

• कर रही है
• इससे भी कम या ज्यादा प्रभावी
• यहां तक ​​कि संसाधन कार्यकर्ता के भीतर कोरटाइन के बीच फेरबदल करते हैं।
• अभी भी कोई अतिरिक्त बाहरी निर्भरता नहीं हैं

• अजवाइन चलाने के बारे में अजवाइन को कुछ भी पता नहीं है
• आप कार्यों के निष्पादन पर नियंत्रण खो देते हैं
• आप अपवादों पर नियंत्रण खो देते हैं
• बॉयलरप्लेट

समस्या का निरूपण

• कार्य करना चाहिए
• Coroutines प्रतिस्पर्धी होना चाहिए
• संसाधनों को कई निष्पादन योग्य के बीच साझा किया जाना चाहिए
• कोई बॉयलरप्लेट नहीं
• सिंपल प्रेडिक्टेबल एपीआई

import asyncio

from .celeryapp import celeryapp


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

सारांश

संक्षेप में सुविधाएँ

• अतुल्यकालिक कार्य शेडिंग
• अजवाइन के संकेतों में Corutin का समर्थन

योजनाओं

उदाहरण

अन्य