回答

0

只有全球水平7日到期,我不能重試配置此。但是,您可以添加時間戳作爲屬性,並在管道的開始處檢查時間戳,然後在滿足條件的情況下丟棄時間戳。

也就是說,我們不建議您只使用時間戳來確定是否丟棄該消息,因爲如果您的積壓量很大而消費者無法趕上,則有可能引發有效消息即使這是第一次被處理,也是如此。

這是另一個想法。發佈消息時,您會在API響應中獲取消息ID,稍後可以使用它來標識單個消息。在您的管道中,您可以遞增每個消息ID的重試次數,以便知道特定消息發生重試的次數。然後,您可以扔掉超過N次重試的郵件。我認爲這個策略更可靠。這些重試次數不是關鍵的事情,所以您可能只能將它們存儲在內存中。