Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion docs/question/运行问题.md
Original file line number Diff line number Diff line change
Expand Up @@ -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)

Expand Down
2 changes: 1 addition & 1 deletion feapder/core/collector.py
Original file line number Diff line number Diff line change
Expand Up @@ -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",
Expand Down
8 changes: 4 additions & 4 deletions feapder/utils/metrics.py
Original file line number Diff line number Diff line change
Expand Up @@ -427,7 +427,7 @@ def emit_any(
fields: influxdb的field的字段和值
classify: 点的类别
measurement: 存储的表
timestamp: 点的时间搓,默认为当前时间
timestamp: 点的时间戳,默认为当前时间

Returns:

Expand Down Expand Up @@ -458,7 +458,7 @@ def emit_counter(
classify: 点的类别
tags: influxdb的tag的字段和值
measurement: 存储的表
timestamp: 点的时间搓,默认为当前时间
timestamp: 点的时间戳,默认为当前时间

Returns:

Expand Down Expand Up @@ -489,7 +489,7 @@ def emit_timer(
classify: 点的类别
tags: influxdb的tag的字段和值
measurement: 存储的表
timestamp: 点的时间搓,默认为当前时间
timestamp: 点的时间戳,默认为当前时间

Returns:

Expand Down Expand Up @@ -520,7 +520,7 @@ def emit_store(
classify: 点的类别
tags: influxdb的tag的字段和值
measurement: 存储的表
timestamp: 点的时间搓,默认为当前时间
timestamp: 点的时间戳,默认为当前时间

Returns:

Expand Down