
Series: Queue

緣由 因為工作學了rabbitMQ,所以閒暇之餘來學kafka,想知道兩者的差異 比較 速度 訊息保證 訊息大

任務定義 將裝飾器綁到函數 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[, …]])

緣由 在工作上,遇到單機已經過多負荷,所以開始做實作分散式爬蟲 Celery定義 分散式任務隊列處理 架構 任

TaskQueue & MessageQueue 傳送物件 抽象層級 主要設定 相同 Tq 任務 高(基於mq的封裝) 任務的使用方式與處理 異步與分散式 Mq 訊息 低

MessageQueue(MQ) 訊息貯列,協助訊息以非同步方式溝通,常見協議MQTT,AMQP 訊息代理人 經紀人Broker 訊息發送

緣由 在工作上,因為需要導入發布訂閱模式,故在幾種常見的Mq中做選擇 發布/訂閱 速度 訊息保證 訊息大小 訊息
latest Posts
WebSocket
緣由 因寫side project重新接觸到WebSocket,順便理清以前模糊的概念 關於WebSock
2025-5-11
優雅停止程式
緣由 因為工作加入新專案,看到對停止程式有專門做處理,才回頭思考自己對這部分的研究不足 關於OS訊號 通常
2025-5-11
ReadMoo 電子書爬蟲
緣由 因閱讀電子書,一直有畫重點的習慣,但官方提供的匯出csv或html,沒有排序,也有輸出總量的限制
2025-1-27
電子書重點整理
總書單 致富覺察 多巴胺國度 勝算 快思慢想 晶片戰爭 給予 花掉的錢都會自己流回來 一個投機者的告白之金錢遊戲 一個
2025-1-27
Message Queue[三] Kafka
緣由 因為工作學了rabbitMQ,所以閒暇之餘來學kafka,想知道兩者的差異 比較 速度 訊息保證 訊息大
2024-11-23