worker

1熱度

1回答

我下面Heroku的文檔中關於workers，但從來沒有成功過。有一個模塊util.py，將運行作爲後臺作業： util.py： import requests def count_words_at_url(url): resp = requests.get(url) return len(resp.text.split()) 而且把utils.py到工人的隊列： fr

1熱度

2回答

確保單個任務實例正在運行的分佈式工作人員

我需要設計一個分佈式系統，調度程序將任務發送給多個節點中的工作人員。每個任務都分配一個ID，並且可以多次執行，由調度程序調度（通常每小時一次）。我唯一的要求是，具有特定ID的任務不應該在兩次由集羣同時執行。我可以想象一個設計，其中調度程序爲每個任務ID保存一個鎖並將任務發送給適當的工作人員。一旦工作人員完成鎖定應該被釋放，調度器可能再次安排。我應該我的設計包括以確保這一點。我擔心任務發送給啓動

0熱度

1回答

C＃WPF將worker.cs中的工作人員信息推送到Home.xaml

我是WPF中的新手，現在我嘗試了幾天。在我的MainWindow.xaml.cs中，我創建了一個新的工作實例。 public MainWindow() { InitializeComponent(); Worker worker = new Worker(); worker.run_Worker(); } 的MainWindow.xam

1熱度

1回答

Ruby on Rails的錯誤使用運動鞋與RabbitMQ的

我使用的運動鞋的寶石來觸發的RabbitMQ 的行動，但我不能啓動我的服務觸發我運行命令 WORKERS=MailerWorker rake sneakers:run ，我得到了誤差 [INFO] 160825 14:26:46 :: LAUNCH worker rake aborted! NameError: uninitialized constant ApplicationCabl

2熱度

3回答

AWS Elasticbeanstalk cron.yaml工人問題

我有部署Elasticbeanstalk和運行作爲工人的應用程序，我想添加一個週期性任務TI運行的每個小時，所以我創建這個CONF一個cron.yaml： version: 1 cron: - name: "task1" url: "/task" schedule: "00 * * * *" 但部署過程中，我總是得到這個錯誤： [Instance: i-a072

1熱度

3回答

池多重處理Python

基本上這個問題如下：我有一堆工作人員，每個工作人員都有一個函數（函數是worker（alist）），並且試圖同時處理35名工人。每個工作人員從文件（模數部分）中讀取他們的行，並使用「工作人員」功能處理該行。我進行了筆測，發現無用指數的原始操作和刪除按預期工作100％。「pool.apply_async」函數的args部分未將「raw」列表傳入並啓動該進程。 Raw是完全正確的，並且正常工作，wo

0熱度

1回答

在Golang中實現「事件」（包含通知者/接收者）的概念？

我想知道在Golang中處理「事件」（包含通知器/接收器）概念的正確方法是什麼。我想我需要使用渠道，但不知道最好的方法。具體來說，我有兩名工人下面的程序。在某些情況下，「worker1」進入和退出「快速模式」並通過通道通知。然後「worker2」可以接收此事件。這工作正常，但這兩名工人緊密相連。特別是，如果worker2未運行，則在寫入通道時，worker1會停滯不前。 Golang的最佳實施方

0熱度

1回答

創建php rabbit worker的最佳方法

假設我有經常充滿一些數據的兔子隊列（例如，用戶提供了一些我們需要稍後分析的動作）。每秒鐘新增30個項目。我需要的是創建一個工作人員，通過這個隊列來查看這個數據並執行一些任務。我可以這樣做： class Worker { public function run() { $queue = new Queue('exchange', 'queue');

0熱度

1回答

Apache Storm未正常運行，worker.log生成異常

我正在使用Apache Kafka的Apache風暴。使用的噴嘴是卡夫卡噴嘴，但它不會讀取卡夫卡主題中的任何內容。我不知道這是否與我在風暴工作人員面臨的問題有關。如果您知道任何相關解決方案，請告訴我並通知我。風暴拓撲成功上傳到Storm。我拿來的日誌和這裏是工人們在他們的worker.log文件寫着： java.lang.ExceptionInInitializerError at j

0熱度

1回答

如何從UI線程訪問工作線程？

我有一個工作線程在整個運行時期間運行，它們生成事件。我可以使用disp = Windows::UI::Core::CoreWindow::GetForCurrentThread()->Dispatcher在UI線程內處理這些事件。更確切地說，我通過在工作線程中的任何地方使用disp->RunAsync(...)來修改UI。但我不知道如何做倒置操作。我想在UI線程內部有一些Async函數來在工