Efektyvus salierų, „CeleryBeat“, „Flower“ ir „FastAPI“ valdymas „DevContainers“

Dinaminė „Docker“ sąranka, skirta „FastAPI“, „Celery“ ir susijusioms paslaugoms

Šiame scenarijuje naudojamas „Python“ su „Docker Composi“, kad būtų sukonfigūruotas dinaminis paslaugų valdymas kūrimo aplinkoje. Paslaugos nustatomos tik tada, kai reikia, optimizuodami išteklių naudojimą.

# Docker Compose file with profiles for selective service activation
version: '3.8'
services:
  trader:
    build:
      context: ..
      dockerfile: .devcontainer/Dockerfile
    volumes:
      - ../:/app:cached
      - ~/.ssh:/home/user/.ssh:ro
      - ~/.gitconfig:/home/user/.gitconfig:cached
    command: sleep infinity
    environment:
      - AGENT_CACHE_REDIS_HOST=redis
      - DB_URL=postgresql://myuser:mypassword@postgres:5432/db
    profiles:
      - default
  celery:
    build:
      context: ..
      dockerfile: .devcontainer/Dockerfile
    volumes:
      - ../:/app:cached
    command: celery -A src.celery worker --loglevel=debug
    environment:
      - AGENT_CACHE_REDIS_HOST=redis
      - DB_URL=postgresql://myuser:mypassword@postgres:5432/db
    profiles:
      - optional
  redis:
    image: redis:latest
    networks:
      - trader-network
    profiles:
      - default

Salierų paleidimo optimizavimas naudojant Python scenarijų

Šis „Python“ scenarijus automatizuoja salierų paslaugų paleidimą, pagrįstą vartotojo veiksmais. Jis naudoja „Docker SDK“ „Python“, kad galėtų valdyti konteinerius.

import docker
def start_optional_services():
    client = docker.from_env()
    services = ['celery', 'celerybeat', 'flower']
    for service in services:
        try:
            container = client.containers.get(service)
            if container.status != 'running':
                container.start()
                print(f"Started {service}")
            else:
                print(f"{service} is already running")
        except docker.errors.NotFound:
            print(f"Service {service} not found")
if __name__ == "__main__":
    start_optional_services()

Vieneto salierų darbo eiga testavimas

Šis „Python“ bandomasis scenarijus naudoja „Pytest“, kad patvirtintų „Celery“ užduočių vykdymo aplinką, užtikrinant moduliškumą ir teisingumą.

import pytest
from celery import Celery
@pytest.fixture
def celery_app():
    return Celery('test', broker='redis://localhost:6379/0')
def test_task_execution(celery_app):
    @celery_app.task
    def add(x, y):
        return x + y
    result = add.delay(2, 3)
    assert result.get(timeout=5) == 5

Dažnai užduodami klausimai apie „Docker“ ir salierų integraciją

1. Koks yra „Docker Compose“ profilių tikslas?
2. Jie leidžia sugrupuoti paslaugas į logines kategorijas, leidžiančias selektyviai paleisti konteinerius. Pvz., „Numatytasis“ profilyje gali būti tokios pagrindinės paslaugos kaip „Fastapi“, o „pasirenkamas“ profilis apima Celery darbininkų.
3. Kaip pradėti teikti konkrečią paslaugą iš pasirenkamo profilio?
4. Naudokite komandą docker compose --profile optional up celery Norėdami pradėti tik konteinerius „pasirenkamame“ profilyje.
5. Koks yra „Docker SDK“ naudojimo konteinerių valdymui pranašumas?
6. Docker SDK leidžia programiškai valdyti konteinerius, pvz., dinamiškai paleisti arba sustabdyti konkrečias paslaugas, naudojant Python scenarijus.
7. Kaip galiu stebėti Salierų užduotis realiuoju laiku?
8. Galite naudoti „Flower“, internetinę stebėjimo įrankį. Pradėkite jį naudodami celery -A app flower Norėdami peržiūrėti užduoties eigą ir žurnalus per žiniatinklio sąsają.
9. Kuo naudinga valdyti salierų darbuotojus tik pagal pareikalavimą?
10. Tai taupo išteklius ir vengia nereikalingų API skambučių. Pvz., Galite atidėti pradinius darbuotojus, kol konkretūs integracijos testai reikės apdoroti foną.

Efektyvus konteinerių valdymas kūrėjams

Efektyvus plėtros išteklių valdymas yra labai svarbus siekiant išlaikyti produktyvumą. Selektyviai paleidę tokias paslaugas kaip „Selery“ ir „Flower“, kūrėjai gali sutelkti dėmesį į kūrimo funkcijas be nereikalingų trukdžių. „Docker Compose“ profiliai supaprastina šį procesą ir užtikrina, kad ištekliai būtų naudojami protingai.

Scenarijai ir testavimo sistemos dar labiau sustiprina šią sąranką teikdami dinaminį paslaugų aktyvavimą ir patvirtinimą. Šie įrankiai kartu suteikia lanksčią ir tvirtą aplinką, leidžiančią kūrėjams lengvai derintis, išbandyti ir diegti savo „FastApi“ programas. 🌟