From 909febbe1da090c947e0a3592de902936dd44292 Mon Sep 17 00:00:00 2001 From: linsanxian Date: Thu, 27 Mar 2025 17:01:00 +0800 Subject: [PATCH] =?UTF-8?q?docs(core):=20=E4=BF=AE=E6=AD=A3=E6=96=87?= =?UTF-8?q?=E6=A1=A3=EF=BC=8C=E6=8F=8F=E8=BF=B0=E4=B8=AD=E7=9A=84=E9=94=99?= =?UTF-8?q?=E5=88=AB=E5=AD=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 将"时间搓"修正为"时间戳" --- .../\350\277\220\350\241\214\351\227\256\351\242\230.md" | 2 +- feapder/core/collector.py | 2 +- feapder/utils/metrics.py | 8 ++++---- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git "a/docs/question/\350\277\220\350\241\214\351\227\256\351\242\230.md" "b/docs/question/\350\277\220\350\241\214\351\227\256\351\242\230.md" index cbc84e3b..ade03f4d 100644 --- "a/docs/question/\350\277\220\350\241\214\351\227\256\351\242\230.md" +++ "b/docs/question/\350\277\220\350\241\214\351\227\256\351\242\230.md" @@ -21,7 +21,7 @@ delete_keys为需要删除的key，类型: 元组/bool/string，支持正则; 常用于清空任务队列，否则重启时会断点续爬，如写成`delete_keys=True`也是可以的 -1. 手动修改任务分数为小于当前时间搓的分数 +1. 手动修改任务分数为小于当前时间戳的分数 ![-w917](http://markdown-media.oss-cn-beijing.aliyuncs.com/2021/03/11/16154327722622.jpg) diff --git a/feapder/core/collector.py b/feapder/core/collector.py index 4e063a7b..5b8ff652 100644 --- a/feapder/core/collector.py +++ b/feapder/core/collector.py @@ -63,7 +63,7 @@ def __input_data(self): current_timestamp = tools.get_current_timestamp() - # 取任务，只取当前时间搓以内的任务，同时将任务分数修改为 current_timestamp + setting.REQUEST_LOST_TIMEOUT + # 取任务，只取当前时间戳以内的任务，同时将任务分数修改为 current_timestamp + setting.REQUEST_LOST_TIMEOUT requests_list = self._db.zrangebyscore_set_score( self._tab_requests, priority_min="-inf", diff --git a/feapder/utils/metrics.py b/feapder/utils/metrics.py index 2fd4f178..ab88ee1e 100644 --- a/feapder/utils/metrics.py +++ b/feapder/utils/metrics.py @@ -427,7 +427,7 @@ def emit_any( fields: influxdb的field的字段和值 classify: 点的类别 measurement: 存储的表 - timestamp: 点的时间搓，默认为当前时间 + timestamp: 点的时间戳，默认为当前时间 Returns: @@ -458,7 +458,7 @@ def emit_counter( classify: 点的类别 tags: influxdb的tag的字段和值 measurement: 存储的表 - timestamp: 点的时间搓，默认为当前时间 + timestamp: 点的时间戳，默认为当前时间 Returns: @@ -489,7 +489,7 @@ def emit_timer( classify: 点的类别 tags: influxdb的tag的字段和值 measurement: 存储的表 - timestamp: 点的时间搓，默认为当前时间 + timestamp: 点的时间戳，默认为当前时间 Returns: @@ -520,7 +520,7 @@ def emit_store( classify: 点的类别 tags: influxdb的tag的字段和值 measurement: 存储的表 - timestamp: 点的时间搓，默认为当前时间 + timestamp: 点的时间戳，默认为当前时间 Returns: