Python'da asyncio ile Asenkron Kod Yazmak: Görev, gather ve Zaman Aşımı

asyncio ne zaman işe yarar?

Bir programın zamanının büyük kısmı bekleyerek geçiyorsa, o beklemeyi başka işler için kullanmak mümkündür. Örneğin bir hizmetin çok sayıda dış adrese istek göndermesi gerekiyor. İstekleri sırayla göndermek, her yanıtı beklerken işlemciyi boşta bırakır. asyncio'da bekleyen iş kontrolü olay döngüsüne geri verir, döngü de o sırada hazır olan başka bir işi çalıştırır.

Burada kritik nokta şudur: asyncio tek iş parçacığında çalışır ve işleri gerçekten paralel yürütmez, sırayla ama iç içe yürütür. Bu yüzden kazanç, bekleme süresinin örtüşmesinden gelir. Ağır sayısal hesaplama gibi işlemciyi yoran işlerde asyncio hız getirmez; orada süreç tabanlı paralellik gerekir. Genel kavram için asenkron programlama sözlük maddesine bakılabilir; burada Python'a özgü uygulama anlatılıyor.

async def, await ve asyncio.run ile ilk program

Bir fonksiyonu async def ile tanımladığınızda onu çağırmak kodu çalıştırmaz, bir eşyordam nesnesi döndürür. Eşyordamın çalışması için ya await ile beklenmesi ya da göreve çevrilmesi gerekir. await yalnız async def içinde kullanılır. Programın en üstünde ise asyncio.run ile ana eşyordam başlatılır.

import asyncio

async def sayfa_getir(adres): yanit = await istemci.get(adres) return yanit.status_code

async def main(): kod = await sayfa_getir("https://ornek.com") print(kod)

asyncio.run(main())

Örnekteki istemci, aiohttp ya da httpx gibi asenkron bir HTTP kütüphanesinden gelen nesneyi temsil eder. Sık yapılan ilk hata, await yazmayı unutmaktır: sonuç yerine eşyordam nesnesi elde edersiniz ve Python, hiç beklenmediğini belirten bir uyarı verir.

Eşzamanlı çalıştırma: create_task, gather ve TaskGroup

Birden fazla işi gerçekten örtüştürmek için eşyordamları göreve çevirmek gerekir. Arka arkaya await eden bir döngü işleri yine sıraya dizer. Yaygın yollar şunlardır:

• asyncio.create_task: Eşyordamı hemen zamanlar ve bir görev döndürür. Görevin referansını tutun; döngü yalnız zayıf referans saklar ve unutulan görev beklenmedik biçimde silinebilir.
• asyncio.gather: Birçok eşyordamı birlikte çalıştırır, sonuçları girdi sırasıyla döndürür. Varsayılanda ilk hata yukarı çıkar ama diğer işler iptal edilmez. return_exceptions=True verirseniz hatalar da sonuç listesine girer.
• asyncio.TaskGroup: Bir bağlam yöneticisidir. Bir görev başarısız olursa kalan görevler iptal edilir ve hatalar bir ExceptionGroup olarak yükselir. Python belgeleri bunu gather'a göre daha güçlü güvenlik garantileri veren, daha modern bir yol olarak tanımlar.

Kısa kural: sonuçları toplu ve hataya dayanıklı almak istiyorsanız gather'ı return_exceptions ile, bir işin çökmesi tüm grubu durdurmalıysa TaskGroup'u seçin. TaskGroup Python'un yeni sürümlerinde vardır; eski sürümde gather ile devam edersiniz.

async with asyncio.TaskGroup() as grup: gorevler = [grup.create_task(sayfa_getir(a)) for a in adresler] sonuclar = [g.result() for g in gorevler]

Zaman aşımı ve iptal

Dış bir sisteme istek gönderen her akışta bir üst süre belirlemek gerekir. Yanıt hiç gelmezse görev sonsuza dek bekler ve geri kalan işleri de tutar. Başlıca araçlar şunlardır: asyncio.timeout bir bağlam yöneticisidir; süre dolunca içindeki görevi iptal eder ve bunu TimeoutError'a çevirir. Bu hatayı bloğun dışında yakalarsınız. asyncio.wait_for ise tek bir beklemeyi sınırlar, süre dolunca beklenen işi iptal eder ve TimeoutError verir.

try: async with asyncio.timeout(sure): await sayfa_getir(adres) except TimeoutError: print("yanıt gelmedi")

İptal, görevin içinde CancelledError olarak görünür. Bu hata Exception değil BaseException alt sınıfıdır, bu yüzden genel bir except Exception onu yakalamaz; temizlik için try/finally kullanın. CancelledError'ı yakalarsanız yeniden fırlatmak genellikle doğrudur, çünkü iptali bastırmak Python belgelerinde önerilmez.

Kurgusal bir örnek: bir raporlama servisi, her sabah çok sayıda iç hizmetten veri toplasın. Arka arkaya await edildiğinde toplam süre tüm yanıt sürelerinin toplamı olur; gather ya da TaskGroup ile toplandığında ise en yavaş yanıt kadar sürer. Aynı akışa her istek için bir zaman aşımı eklenirse, yanıt vermeyen tek bir hizmet raporun tamamını geciktirmez; o hizmetin verisi eksik işaretlenir ve rapor diğerleriyle üretilir.

En sık hata: olay döngüsünü bloklamak

asyncio'nun görünmez tuzağı, async def içinde bloklayan bir çağrı yapmaktır. time.sleep, senkron bir HTTP kütüphanesi ya da büyük bir dosyayı eşzamanlı okumak, olay döngüsünü kilitler; bu sırada diğer tüm görevler beklemek zorunda kalır. Kod hatasız çalışır ama beklenen hızlanma gelmez.

Çözüm iki yönlüdür. Mümkünse işin asenkron karşılığını kullanın: bekleme için asyncio.sleep, istek için asenkron istemci. Asenkron karşılığı olmayan kütüphane için asyncio.to_thread, fonksiyonu ayrı bir iş parçacığında çalıştırıp sonucu eşyordam olarak döndürür. Python belgeleri bunun esas olarak giriş-çıkış bağımlı fonksiyonlar için olduğunu belirtir, çünkü GIL işlemci yükünü iş parçacığında hızlandırmaz.

Bir diğer sık hata, görevleri başlatıp sonuçlarını hiç beklememektir. Başlatılan her görev ya await edilmeli ya bir TaskGroup içinde olmalı ya da referansı tutulmalıdır; aksi halde hatalar sessizce kaybolur.

Öğrenme yolu ve Mindset programlarındaki yeri

Sağlam bir sıra şöyledir: önce senkron Python ve hata yönetimini rahat kullanın; ardından tek bir async def ile asyncio.run, sonra gather ile birkaç istek, sonra zaman aşımı ve iptal, en sonda TaskGroup ve asenkron bir web çerçevesi. Her adımda küçük bir uygulama yazın: birkaç adrese istek atıp sonuçları toplayan bir betik, ardından aynısını zaman aşımıyla.

Mindset kataloğunda Python ile web geliştirme (FastAPI) programı asenkron programlama ve arka plan görevleri modülünü içerir; asyncio'ya odaklı program ise eşzamanlılık modellerinden zaman aşımı, iptal ve geri basınca kadar uzanır. Python'da eşzamanlılık ve performans programı asyncio'yu GIL, iş parçacığı ve süreç yaklaşımlarıyla birlikte karşılaştırmalı ele alır; bu da hangi işin hangi yöntemle çözüleceğine karar vermek isteyenler için uygundur.