eventlet

    1熱度

    1回答

    這篇文章是在延續與我以前的帖子 - celery how to implement single queue with multiple workers executing in parallel? 我實現了芹菜eventlet使用此命令的工作: - celery -A project worker -P eventlet -l info --concurrency=4 我可以看到我的任務是獲

    1熱度

    1回答

    我們有一個Django webapp,它使用Celery 4.x異步運行任務。主要任務需要Django/Celery代碼與20-100臺其他服務器執行網絡通信操作。我們發送給這些其他服務器的每個請求都是相同的,即用戶向Django發送一條命令,然後告訴Celery向20-100臺其他服務器發送完全相同的命令。問題在於,對於Celery的基本配置,如果我們有4名員工,那麼Celery將只與4臺服務器

    0熱度

    1回答

    你好,我有一個django應用程序。我的整個系統配置如下:python 3,django 1.11,eventlet 0.21.0。 1)Nginx的作爲上游服務器: upstream proj_server { server unix:///tmp/proj1.sock fail_timeout=0; server unix:///tmp/proj2.sock fail_

    0熱度

    1回答

    我想用線程一次下載多個文件。 這是我已經試過: import eventlet from urllib.request import urlopen def fetch(url, fl): urllib.request.urlretrieve(url, fl) return url, fl pool = eventlet.GreenPool() for url, f

    0熱度

    1回答

    我正在使用使用eventlet用Python編寫的一個服務器端的端點和用JavaScript編寫客戶端起始點的WebSockets: var ws = new WebSocket("ws://192.168.1.25:16081/some_url"); ws.onopen = function() { console.log("Transmitting " + data)

    0熱度

    1回答

    假設我們有這是一個事件驅動單線程服務器上承載的WSGI應用: from eventlet import wsgi import eventlet def app(env, start_response): # IO opeartions here ... wsgi.server(eventlet.listen(('', 8090)), app) 在應用程序的功能,

    1熱度

    1回答

    早上好, 我們正面臨Python上Eventlet和WSGI服務器的一個相當奇怪的問題。我們正試圖從登錄這些線路 (5757) accepted ('y.x.z.88', 52344) (5757) accepted ('y.x.z.88', 52621) 我們在WSGI服務器設置試圖進行以下設置停止 wsgi.server(eventlet.listen(('1.2.3.4', 8000)

    0熱度

    1回答

    我正在創建一個使用eventlet greenthreads的簡單程序,我無法理解它們的行爲。從下面的例子看來,線程只在我調用.wait()方法時運行。我閱讀文檔,找不到類似於線程模塊提供的「啓動」方法的任何方法。有沒有類似的方法來強制線程在創建之後運行(spawn call)? Python 2.7.6 (default, Oct 26 2016, 20:30:19) [GCC 4.8.4]

    1熱度

    2回答

    我有一個Django項目。我使用的軟件包:Django 1.11,Eventlet 0.21.0。 Python版本是3.4.3。 有以下配置文件: 1)主項目的配置文件settings.py。導入其他兩個配置文件中的一個是主要角色。 try: from .settings_local import * except ImportError: from .conf.commo

    0熱度

    1回答

    我在嘗試將eventlet/queue放入某​​個項目時不時發現奇怪的異常。 for message in kafka_consumer: queue_in.put(message.value) packages/eventlet/queue.py", line 265, in put assert result is waiter, "Invalid switch int