|
@@ -55,7 +55,7 @@ class HandleFailedItems:
|
|
|
for message in failed_items:
|
|
for message in failed_items:
|
|
|
delivery_tag = message.delivery_tag
|
|
delivery_tag = message.delivery_tag
|
|
|
data = message.body
|
|
data = message.body
|
|
|
- del data[self._redis_key] # 添加item失败标识
|
|
|
|
|
|
|
+ del data[self._redis_key] # 删除item数据标识
|
|
|
for add in data.get("add"):
|
|
for add in data.get("add"):
|
|
|
table = add.get("table")
|
|
table = add.get("table")
|
|
|
datas = add.get("datas")
|
|
datas = add.get("datas")
|
