Home
Posts
Categories
Series
Tags
About

Tag: distributed task queue

image loading failed
postedOn: 2024-1-27   updatedOn: 2024-1-27   includedIn: 程式
任務定義 將裝飾器綁到函數 celery = Celery(__name__,broker=broker) @celery.task def add(x: int, y: int) -> int: time.sleep(5) return x + y add 就是一個task 任務使用 完整版 apply_async(args[, kwargs[, …]])
image loading failed
postedOn: 2024-1-27   updatedOn: 2024-1-27   includedIn: 程式
緣由 在工作上,遇到單機已經過多負荷,所以開始做實作分散式爬蟲 Celery定義 分散式任務隊列處理 架構 任
image loading failed
postedOn: 2024-1-26   updatedOn: 2024-1-26   includedIn: 程式
TaskQueue & MessageQueue 傳送物件 抽象層級 主要設定 相同 Tq 任務 高(基於mq的封裝) 任務的使用方式與處理 異步與分散式 Mq 訊息 低
image loading failed
postedOn: 2023-11-18   updatedOn: 2023-11-18   includedIn: 程式
MessageQueue(MQ) 訊息貯列,協助訊息以非同步方式溝通,常見協議MQTT,AMQP 訊息代理人 經紀人Broker 訊息發送
image loading failed
postedOn: 2023-11-18   updatedOn: 2023-11-18   includedIn: 程式
緣由 在工作上,因為需要導入發布訂閱模式,故在幾種常見的Mq中做選擇 發布/訂閱 速度 訊息保證 訊息大小 訊息