task-queue

0熱度

2回答

在谷歌應用程序引擎中，當您將任務添加到同一個推送任務隊列時，它們是否會按照時間順序排列？或者是否有可能一個任務可以在另一個任務之前執行，儘管它最後被添加了？（這是假設他們正在使用相同的隊列）。

0熱度

1回答

我是新來的Python和芹菜，Redis的，所以請糾正我，如果我的理解是不正確的芹菜儲存任務結果。我一直在調試代碼庫一種結構類似 - TaskClass - >芹菜任務 HandlerClass1, HandlerClass2 - >這些Python類擴展對象類應用程序創建TaskClass說dumyTask實例和dumyTask創建芹菜子任務（我相信這些子任務是唯一的）說dumySubTas

0熱度

2回答

保證在GAE中只添加一個任務推送隊列一次

我想確保任務—特別是在單個實體上運行的任務—最多被添加到推送隊列中，直到這樣一個時間之前添加的任務已完成。然後，我應該可以再次爲同一個實體—添加相同的任務—。一個簡單的例子是，更新實體答：我希望能夠到一個任務：添加任務X到實體A更新到推隊列。雖然任務X位於實體A的隊列中，但爲實體A添加任務X的所有其他嘗試都會失敗。一旦完成，我要再次可以添加任務X爲實體A. 簡單的解決方案似乎是使用結合任務

1熱度

2回答

在AppEngine標準環境中使用Java創建線程

我是Google Cloud Platform中的新成員。我正在使用AppEngine標準環境。我需要在java中創建主題，但我認爲這是不可能的，是嗎？這裏的情況是：我需要創建訂閱供用戶使用。有三個數據庫名稱爲d1, d2, d3。每當用戶發送請求時，Java會創建三個線程，每個數據庫一個線程。例如t1代表d1，t2代表d2和t3代表d3。這些線程必須異步運行才能獲得更好的性能，之後將這3

1熱度

3回答

Google App Engine - 隊列結束時的事件

我開始構建批量上傳工具，並試圖解決如何完成其中一項要求。這個想法是，用戶將上傳一個CSV文件，該工具將解析它，並將CSV的每一行發送到任務隊列作爲要運行的任務。然後，一旦完成了與該特定CSV文件有關的所有任務，就會向用戶發送摘要報告。我使用的是Google App Engine，過去我使用標準任務隊列來處理任務。但是，使用標準任務隊列時，無法知道隊列何時完成，因此不會觸發事件觸發報告生成，

0熱度

1回答

使用芹菜分配數學處理

介紹嗨，我是超新於一般，所以我有一個問題，可能是相當幼稚的芹菜和任務隊列。我想要一個相當大的.csv文件（將其轉換爲pandas DataFrame）並在所有列對上對其執行皮爾遜測試（統計數學函數）。大約需要9分鐘到一個核心，我們有數百個.csv文件！所以我想在我們的3臺服務器集羣上的所有內核之間劃分這個處理。這裏有一個原型的我的代碼迄今.... from celery import Cel

0熱度

1回答

爲什麼隊列上的GAE任務運行得比指定的更頻繁？

我有一個隊列定義如下： .... <queue> <name>sendMailsBatch</name> <rate>1/m</rate> <max-concurrent-requests>1</max-concurrent-requests> <retry-parameters> <min-backoff-seconds>70</min-ba

2熱度

1回答

谷歌AppEngine無法推遲sendmail作業默認taskqueue，收到未經授權的發件人錯誤

您好，我試圖推遲通過sendmail發送郵件。能夠發送郵件沒有問題。只要我嘗試deferred.defer(send_invitation,recipient)，它就停止工作。我可以看到任務重試最大允許的極限，以及日誌顯示： File "/base/data/home/runtimes/python27/python27_lib/versions/1/google/appengine/api

0熱度

2回答

golang：防止同級錯誤重置連接的策略

該程序同時產生許多goroutines（getStock），我相信這會導致遠程服務器立即丟棄連接。我不是想創建一個DOS，但我仍然想要積極獲取數據而不會發生「連接重置」錯誤。什麼是一些策略最多隻有N（例如20）同時連接？在golang Http客戶端中有GET請求的內置隊列嗎？我還在學習，如果對這種類型的代碼有更好的設計模式，那將是很好的理解。輸出 $ go run s1w.go sl(si

3熱度

1回答

有沒有辦法使用App Engine Java運行時動態地設置任務的目標？</p> <pre><code>task = taskqueue.add( url='/update_counter', target='worker', params={'amount': amount}) </code></pre> <p>有沒有辦法在執行此操作：

當排隊與App Engine的Python運行一個後臺任務，你可以specify a target for the queue將發送任務，要在一個特定的服務，版本或實例上運行Java的？文檔mentions the target parameter但未顯示如何使用它的示例。 Queue.add方法沒有target的選項。 TaskOptions類別沒有任何類似target的任何東西。 This q