pdkj
/
lcny-cameras-healthbeat
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update

master
Jing Li 2024-04-09 23:19:23 +08:00
parent 7107c3a156
commit dc59e46d7d
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
Healthbeat.py
View File

@ -1,6 +1,7 @@
# coding=utf-8
import os
import cv2
import re
import logging
import psycopg2
import threading
@ -64,17 +65,20 @@ if __name__ == '__main__':
with conn:
with conn.cursor() as cursor:
cursor.execute("SELECT id, status, extends FROM devices WHERE type = 1 AND status in (1, 2) ORDER BY id ASC")
cursor.execute("SELECT id, status, extends FROM devices WHERE type = 1 AND status in (1, 2) ORDER BY id DESC")
rows = cursor.fetchall()
threads = []
for row in rows:
extends = row[2]
if isinstance(extends, dict) and extends["rtsp_url"] != '':
c = Camera(row[0], extends["rtsp_url"], row[1])
t = threading.Thread(target=c.healthbeat)
threads.append(t)
t.start()
if not isinstance(extends, dict) or extends["rtsp_url"] is None or not re.search(r'^rtsp:', extends["rtsp_url"]):
continue
c = Camera(row[0], extends["rtsp_url"], row[1])
t = threading.Thread(target=c.healthbeat)
threads.append(t)
t.start()
for t in threads:
t.join()