diff --git a/app.py b/app.py index b384ce3..839d29a 100644 --- a/app.py +++ b/app.py @@ -484,7 +484,7 @@ def consume_stream(): resp, status_code, recipe_name = add_recipe_from_url(msg['url']) if status_code == 200: r.xack(STREAM_KEY, CONSUMER_GROUP, msg_id) - bark_push(f'{recipe_name} 添加成功') + bark_push(f'{recipe_name} 添加成功', f'地址 {msg["url"]}') else: logger.error(f"Failed to process message: {msg['url']} {resp}") bark_push('食谱添加失败', '%s 来源 %s' % (resp['message'], msg['url']))