Skip to content
Toggle navigation
P
Projects
G
Groups
S
Snippets
Help
lichenggang
/
tas_monitor
This project
Loading...
Sign in
Toggle navigation
Go to a project
Project
Repository
Issues
0
Merge Requests
0
Pipelines
Wiki
Snippets
Settings
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Commit
be0e4b16
authored
Apr 08, 2022
by
陈森彬
Browse files
Options
_('Browse Files')
Download
Email Patches
Plain Diff
update
parent
9bb8e4bc
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
1 additions
and
1 deletions
crawler_process.py
monitor.py
crawler_process.py
View file @
be0e4b16
...
...
@@ -79,6 +79,7 @@ def get_crawler_process_info():
p
=
psutil
.
Process
(
int
(
pid
))
info
=
p
.
as_dict
(
attrs
=
[
'cmdline'
,
'create_time'
,
'cpu_times'
])
info
[
'cmdline'
]
=
{
k
:
v
for
k
,
v
in
zip
(
info
[
'cmdline'
][
2
::
2
],
info
[
'cmdline'
][
3
::
2
])}
print
(
info
)
info_dict
=
dict
()
info_dict
[
'pid'
]
=
pid
.
strip
()
info_dict
[
'task_code'
]
=
info
[
'cmdline'
][
'-r'
]
...
...
monitor.py
View file @
be0e4b16
...
...
@@ -21,7 +21,6 @@ def task_fail_rate_monitor():
while
True
:
try
:
msg
=
get_task_error_rate
(
time_range
=
TIME_INTERVAL
)
print
(
msg
)
if
msg
:
logger
.
info
(
msg
)
dd_send_msg
(
msg
)
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment