Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
230ceb2928 | ||
|
|
458bd91d62 | ||
|
|
9ef43ac554 | ||
|
|
e41cf3181d |
1
.github/FUNDING.yml
vendored
Normal file
1
.github/FUNDING.yml
vendored
Normal file
@@ -0,0 +1 @@
|
||||
custom: ['https://afdian.net/@acgnhiki']
|
||||
17
CHANGELOG.md
Normal file
17
CHANGELOG.md
Normal file
@@ -0,0 +1,17 @@
|
||||
# 更新日志
|
||||
|
||||
## 1.0.3
|
||||
|
||||
- 修复 bug
|
||||
|
||||
## 1.0.2
|
||||
|
||||
- 修复版本号没有更新~
|
||||
|
||||
## 1.0.1
|
||||
|
||||
- 修复了一个小 bug
|
||||
|
||||
## 1.0.0
|
||||
|
||||
- 第一个正式版发布
|
||||
@@ -105,6 +105,12 @@
|
||||
|
||||
---
|
||||
|
||||
## 更新日志
|
||||
|
||||
[CHANGELOG](CHANGELOG.md)
|
||||
|
||||
---
|
||||
|
||||
## 常见问题
|
||||
|
||||
### 如何终止程序?
|
||||
|
||||
@@ -1,3 +1,3 @@
|
||||
|
||||
__version__ = '1.0.0'
|
||||
__version__ = '1.0.3'
|
||||
__prog__ = 'blrec'
|
||||
|
||||
@@ -231,6 +231,8 @@ class StreamRecorder(
|
||||
|
||||
with requests.Session() as self._session:
|
||||
self._main_loop()
|
||||
except TryAgain:
|
||||
pass
|
||||
except Exception as e:
|
||||
self._handle_exception(e)
|
||||
finally:
|
||||
@@ -248,7 +250,6 @@ class StreamRecorder(
|
||||
retry_if_exception(lambda e: not isinstance(e, OSError))
|
||||
),
|
||||
wait=wait_exponential_for_same_exceptions(max=60),
|
||||
stop=stop_after_delay(1800),
|
||||
before_sleep=before_sleep_log(logger, logging.DEBUG, 'main_loop'),
|
||||
):
|
||||
with attempt:
|
||||
|
||||
@@ -179,7 +179,12 @@ class StreamProcessor:
|
||||
|
||||
def _discard_file(self) -> None:
|
||||
curr_path = self._file_manager.curr_path
|
||||
|
||||
self._file_manager.close_file()
|
||||
|
||||
if self._analyse_data:
|
||||
self._data_analyser.reset()
|
||||
|
||||
logger.debug(f'discard file: {curr_path}')
|
||||
|
||||
def _reset(self) -> None:
|
||||
|
||||
Reference in New Issue
Block a user