Как ускорить работу микросервиса с помощью многопоточности, асинхронности и кэша: пошаговая инструкция (FastApi, Redis)

[telesis]

очень хороший туториал, спасибо!!! Такие туториалы интерес к облаку раскачивают и приучают к использованию.

[crion]

Класс... Инициализировать redis во вьюхе это сверх извращения. А ведь кто то поверит что в vk так и делают

[shpaker]

@DimaFromMai согласен с оратором, что это странно. Зачем так сделали то?

[DimaFromMai]

Опечатался просто.

[DimaFromMai]

Поправил.
cache-async-few-threads-microservice.py

Показать...

import fastapi
import httpx
from scrapy.selector import Selector
import aioredis

api = fastapi.FastAPI()
redis = None

@api.on_event('startup')
async def startup_event():
    global redis
    redis = await aioredis.create_redis(address=('redis', 6379))

@api.on_event('shutdown')
async def shutdown_event():
    redis.close()
    await redis.wait_closed()

@api.get('/api/weather/{city}')
async def weather(city: str):
    # redis = await aioredis.create_redis(address=('redis', 6379))

    # get cache from memory
    cache = await redis.get(city)

    # check value from cache, if exists return it
    if cache is not None:
        return {'city':city, 'temperature':cache, 'source':'cache'}

    url = f'https://pogoda.mail.ru/prognoz/{city}/'

    # asynchronous implementation
    async with httpx.AsyncClient() as client:
        response = await client.get(url)
        response.raise_for_status()

    selector = Selector(text=response.text)
    t = selector.xpath('//div[@class="information__content__temperature"]/text()').getall()[1].strip()

    # save cache in memory for 1 hour
    await redis.set(city, t, expire=3600)

    return {'city':city, 'temperature':t, 'source':'pogoda.mail.ru'}