task-queue

2熱度

2回答

如何在Google App Engine中使用模塊並使用任務隊列（Java）向其添加目標？

我的任務超過了任務隊列超過10分鐘的最後期限。通過不同的文檔，我發現使用模塊我可以運行一個實例來處理長時間運行的任務，但最好甚至應該使用任務隊列來完成。我曾經使用後端，但它們已被棄用。我的問題是如何將模塊引入到我現有的App Engine項目中，以及如何使用它們來運行長時間運行的任務？以下是一段代碼： Queue queue = QueueFactory.getQueue("myqueue")

0熱度

1回答

Django：（第三方）應用程序中的衝突模型

我將第三方應用程序集成到我的Django項目中，只有當我導入它時，纔會收到此錯誤消息。 RuntimeError: Conflicting 'task' models in application 'django_q': <class 'django_q.models.Task'> and <class 'models.Task'>. 我很困惑，因爲我的應用程序運行良好沒有它，所以我不知道它是

1熱度

1回答

帶有多個隊列工作器的豆杆設置：產生另一個作業的作業

從作業中產生多個作業是否安全，以便工作人員可以開始處理任何空缺的作業？目前我的設置是這樣的。我有20名工人等待任何工作被推動。其中一項工作是發送iOS推送通知，這是iOS的問題，您無法發送批量消息。當前：我所做的是一個批量獲取特定用戶列表的工作，從我的數據庫獲取每個設備令牌並開始發送通知。場景：如果一個主題有1000個用戶，我必須獲得所有1000個用戶及其設備，然後開始在每個設備上發送。這將

0熱度

1回答

如何爲每個用戶運行單獨的應用程序引擎應用程序實例？

我有一個應用程序執行長時間運行的作業，並將任務推送到任務隊列中。目前，當不同的用戶登錄到應用程序並開始上傳作業時，作業會與現有任務合併，並且預期的輸出不能實現。我最需要的是爲每個用戶運行不同的應用程序引擎應用程序實例，因爲每個用戶都需要大量的計算能力，並且在遇到每個新用戶時都必須動態創建這些實例。我曾經介紹過關於實例類和縮放類型的不同文檔，但並未知道如何爲每個不同的用戶啓動一個新實例。請也建

1熱度

1回答

共享工人的池RabbitMQ的

我建立一個多租戶應用程序，用戶可以提交至工（工人數量是動態的）來處理的任務批我想要實現的是以下幾點：如果我們從一個用戶單批次，已全部工人的信息工作從這個單個用戶如果另一個用戶提交批作業，每個用戶得到一半的工人（以使第一用戶現在以較慢的速度工作，而後來用戶不必等到第一個用戶已經完成了所有的工作冗長）這樣的事情可能與工作隊列？（出於某種原因，感覺就像一個轉折FIFO和隊列的想法，但是這是我的用

2熱度

1回答

谷歌任務隊列REST拉回到500偶爾

我的Python從Google TaskQueue REST API每秒的無限循環的過程租賃的任務： credentials = GoogleCredentials.get_application_default() task_api = googleapiclient.discovery.build('taskqueue', 'v1beta2', credentials=credentials

5熱度

1回答

在C＃中使用MSMQ的驗證異常隊列

我是Windows Server中的Microsoft Message Queue中的新成員，如果EmployeeID爲NULL，則需要推送。的僱員模型類是 public class Employee { public string EmployeeID { get; set; } public string EmployeeName { get; set; } }

1熱度

1回答

使用ETA/Countdown實現TaskQueue（如Celery）

許多流行的任務隊列（例如Google GAE TaskQueue，Celery）都具有ETA /倒計時功能，允許任務在xxx秒後進入隊列。我正在研究需要帶ETA功能的任務隊列的項目。但是，我必須使用Google Pubsub消息傳遞系統纔有一些限制。 Pubsub沒有ETA功能。我想知道如何爲任務隊列實現可靠和可擴展的ETA機制。歡迎使用一般體系結構思想和實際代碼示例。我們的系統每秒排列600

1熱度

1回答

任務隊列完成回調

我正在使用谷歌雲任務隊列來執行一些長時間運行的任務。所有任務完成後，我想發送一些通知。我使用下面的代碼，以獲得我的線程掛起任務的數量 QueueStatistics統計= taskQueue.fetchStatistics（）; stats.getNumTasks（）; 但在這裏我不斷檢查通過getNumTask（）方法返回值。如果它是零，然後我通知其他人。是否有任何回調可用，可以在我的隊

1熱度

1回答

Google appengine：任務隊列性能

我目前有一個應用程序在appengine上運行，我使用延遲庫執行一些作業，其中一些任務每天運行一次，而其中一些任務每月執行一次。這些任務中的大多數都會查詢Datastore以檢索文檔，然後將實體存儲在索引（Search API）中。其中一些表格每月更換一次，我必須在所有實體（4〜5M）上運行這些任務。這樣的任務的一爲例是： def addCompaniesToIndex(cursor=None,