Mengelola Seledri, CeleryBeat, Flower, dan FastAPI secara Efisien di DevContainers

Pengaturan Dynamic Docker untuk FASTAPI, seledri, dan layanan terkait

Skrip ini menggunakan Python dengan Docker Compose untuk mengonfigurasi manajemen layanan dinamis di lingkungan pengembangan. Layanan diatur untuk berjalan hanya ketika diperlukan, mengoptimalkan penggunaan sumber daya.

# 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

Mengoptimalkan Startup Seledri dengan Skrip Python

Skrip Python ini mengotomatiskan permulaan layanan Seledri berdasarkan tindakan pengguna. Ia menggunakan Docker SDK untuk Python untuk mengontrol kontainer.

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

Pengujian Unit Alur kerja seledri

Skrip pengujian Python ini menggunakan Pytest untuk memvalidasi lingkungan eksekusi tugas Seledri, memastikan modularitas dan kebenaran.

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

Pertanyaan Umum Tentang Integrasi Docker dan Seledri

1. Apa tujuan dari profil Docker Compose?
2. Mereka memungkinkan layanan pengelompokan ke dalam kategori logis, memungkinkan startup wadah selektif. Misalnya, profil "default" dapat mencakup layanan penting seperti FastAPI, sedangkan profil "opsional" termasuk Celery pekerja.
3. Bagaimana cara memulai layanan tertentu dari profil opsional?
4. Gunakan perintah docker compose --profile optional up celery untuk memulai hanya penampung di profil "opsional".
5. Apa keuntungan menggunakan SDK Docker untuk mengelola kontainer?
6. Docker SDK memungkinkan kontrol terprogram atas wadah, seperti memulai atau menghentikan layanan tertentu secara dinamis, melalui skrip Python.
7. Bagaimana cara memantau tugas Celery secara real-time?
8. Anda dapat menggunakan Flower, alat pemantauan berbasis web. Mulai menggunakan celery -A app flower untuk melihat kemajuan tugas dan mencatat melalui antarmuka web.
9. Apa manfaat menjalankan pekerja seledri hanya sesuai permintaan?
10. Ini menghemat sumber daya dan menghindari panggilan API yang tidak perlu. Misalnya, Anda dapat menunda memulai pekerja hingga pengujian integrasi tertentu memerlukan pemrosesan tugas latar belakang.

Manajemen Kontainer yang Efisien untuk Pengembang

Mengelola sumber daya pengembangan secara efisien sangat penting untuk mempertahankan produktivitas. Dengan secara selektif memulai layanan seperti seledri dan bunga, pengembang dapat fokus pada pembangunan fitur tanpa gangguan yang tidak perlu. Docker menyusun profil menyederhanakan proses ini, memastikan sumber daya digunakan dengan bijak.

Skrip dan kerangka kerja pengujian lebih lanjut meningkatkan pengaturan ini dengan memberikan aktivasi dan validasi layanan dinamis. Gabungan, alat -alat ini menawarkan lingkungan yang fleksibel dan kuat, memungkinkan pengembang untuk men -debug, menguji, dan menggunakan aplikasi FASTAPI mereka dengan mudah. 🌟