gunicorn uvicorn worker.py limit_concurrency ayarı nasıl yapılır

Aug 19 2020

FastAPI, uvicorn çalışanlarını başlatmak için gunicorn kullanıyor. https://www.uvicorn.org/settings/

Bununla birlikte, gunicorn, uvicorn'u özel ayarlarla başlatmaya izin vermez. https://github.com/encode/uvicorn/issues/343

Sorun, kaynak dosyadaki config_kwargs'ı şu şekilde geçersiz kılmak için önerildi: https://github.com/encode/uvicorn/blob/master/uvicorn/workers.py

Denedik, ancak uvicorn, limit_concurrencykaynaktaki birden çok uvicorn dosyasındaki ayarı onurlandırmıyor :

https://github.com/encode/uvicorn/blob/master/uvicorn/workers.py

# fail

        config_kwargs = {
            "app": None,
            "log_config": None,
            "timeout_keep_alive": self.cfg.keepalive,
            "timeout_notify": self.timeout,
            "callback_notify": self.callback_notify,
            "limit_max_requests": self.max_requests, "limit_concurrency": 10000,
            "forwarded_allow_ips": self.cfg.forwarded_allow_ips,
        }

https://github.com/encode/uvicorn/blob/master/uvicorn/main.py

# fail

    kwargs = {
        "app": app,
        "host": host,
        "port": port,
        "uds": uds,
        "fd": fd,
        "loop": loop,
        "http": http,
        "ws": ws,
        "lifespan": lifespan,
        "env_file": env_file,
        "log_config": LOGGING_CONFIG if log_config is None else log_config,
        "log_level": log_level,
        "access_log": access_log,
        "interface": interface,
        "debug": debug,
        "reload": reload,
        "reload_dirs": reload_dirs if reload_dirs else None,
        "workers": workers,
        "proxy_headers": proxy_headers,
        "forwarded_allow_ips": forwarded_allow_ips,
        "root_path": root_path,
        "limit_concurrency": 10000,
        "backlog": backlog,
        "limit_max_requests": limit_max_requests,
        "timeout_keep_alive": timeout_keep_alive,
        "ssl_keyfile": ssl_keyfile,
        "ssl_certfile": ssl_certfile,
        "ssl_version": ssl_version,
        "ssl_cert_reqs": ssl_cert_reqs,
        "ssl_ca_certs": ssl_ca_certs,
        "ssl_ciphers": ssl_ciphers,
        "headers": list([header.split(":") for header in headers]),
        "use_colors": use_colors,
    }

Uvicorn bu ayarı onurlandırmaya nasıl zorlanabilir? FastAPI'den hala 503 hata alıyoruz

------- GÜNCELLEME ----------- --worker-connections 1000çok sayıda işçiye dağıtılan 100 paralel istek yaparken silahlı mısır ayarı hala 503'e neden oluyor.

Bununla birlikte, bunun biraz daha karmaşık bir konu olduğuna inanıyorum: API uç noktamız çok fazla ağır iş yükü yapıyor, genellikle tamamlanması 5 saniye sürüyor.

2 çekirdekli, 2 işçi ile stres testi:

  • A. 100+ eşzamanlı istek, uç nokta ağır yük - işçi bağlantıları 1
  • B. 100+ eşzamanlı istek, uç nokta ağır yük - işçi bağlantıları 1000
  • C. 100+ eşzamanlı istek, uç nokta düşük yük - işçi bağlantıları 1
  • D. 100+ eşzamanlı istek, uç nokta düşük yük - işçi bağlantıları 1000

Her iki deney A ve B de 503 yanıt verdi, bu nedenle işçi bağlantıları ayarının işe yaradığını varsayarsak, çok fazla eşzamanlı bağlantı 503 hatamıza neden olmuyor gibi görünüyor.

Bu davranıştan dolayı şaşkına dönüyoruz, çünkü gunicorn / uvicorn'un işi sıraya koymasını ve 503 hatası vermemesini bekliyoruz.

Yanıtlar

2 JPG Aug 19 2020 at 11:57

Gönderen gunicorn doc

worker-connections

Maksimum eşzamanlı istemci sayısı.

ve uvicorn doc'tan

limit-concurrency

HTTP 503 yanıtlarını yayınlamadan önce izin verilecek maksimum eşzamanlı bağlantı veya görev sayısı.

Bu bilgiye göre, her iki ayar değişkeni aynı şeyi yapıyor. Yani

uvicorn --limit-concurrency 100 application:demo_app

neredeyse aynı

gunicorn --worker-connections 100 -k uvicorn.workers.UvicornWorker application:demo_app

Not: Bu konuda gerçek bir test yapmadım , lütfen yanılıyorsam düzeltin.


Ayrıca, sınıfı alt sınıflandırarak limit-concurrency(veya limit_concurrency) ayarlayabilirsiniz.uvicorn.workers.UvicornWorker

from uvicorn.workers import UvicornWorker


class CustomUvicornWorker(UvicornWorker):
    CONFIG_KWARGS = {
        "loop": "uvloop",
        "http": "httptools",
        "limit_concurrency": 100
    }

ve şimdi bu kullanmak CustomUvicornWorkerile gunicornolduğu gibi komuta,

gunicorn -k path.to.custom_worker.CustomUvicornWorker application:demo_app

Not: Eğer kontrol edebilirsiniz self.config.limit_concurrencyiçinde CustomUvicornWorkerdeğerinin doğru ayarlanmış sağlamak için sınıfta.