sun15684712291/chache_rtsp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

change

Browse Source
This commit is contained in:
sunyg
2025-10-09 09:20:13 +08:00
parent 21c615bc7f
commit b789d5e58d
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
config.ini
View File

@@ -1,4 +1,4 @@
[config] [config]
urls=rtsp://admin:xkrs0425@172.16.20.15:554/D6/sub/av_stream,rtsp://admin:qd123456@172.16.20.13:554/D4/sub/av_stream urls=rtsp://admin:xkrs0425@172.16.20.15:554/D6/sub/av_stream,rtsp://admin:qd123456@172.16.20.13:554/D4/sub/av_stream
wss=ws://172.16.10.97:8099/websocket/message/rtsp/d6,ws://172.16.10.97:8099/websocket/message/rtsp/d5 wss=ws://172.16.10.97:8099/websocket/message/rtsp/d6,ws://172.16.10.97:8099/websocket/message/rtsp/d5
api=http://172.16.10.97:8099/business/t_monitor_ai/add api=http://172.16.10.97:8099/business/t_monitor_ai/add,http://172.16.10.97:8099/business/t_monitor_ai/add

8
main.py
View File

@@ -27,8 +27,8 @@ def get_config():
config.read(config_path) config.read(config_path)
rtsp_url = config.get('config', 'urls') rtsp_url = config.get('config', 'urls')
wss = config.get('config', 'wss') wss = config.get('config', 'wss')
api_url = config.get('config', 'api') api_urls = config.get('config', 'api')
return wss.split(','), rtsp_url.split(','), api_url return wss.split(','), rtsp_url.split(','), api_urls.split(',')
def process_camera(rtsp_url, ws_url, api_url=None): def process_camera(rtsp_url, ws_url, api_url=None):
@@ -87,10 +87,10 @@ def on_open(ws):
if __name__ == '__main__': if __name__ == '__main__':
websocket_urls, rtsp_urls, api_url = get_config() websocket_urls, rtsp_urls, api_urls = get_config()
for i in range(len(websocket_urls)): for i in range(len(websocket_urls)):
if i == 0: if i == 0:
thread = threading.Thread(target=process_camera, args=(rtsp_urls[i], websocket_urls[i], api_url)) thread = threading.Thread(target=process_camera, args=(rtsp_urls[i], websocket_urls[i], api_urls[i]))
else: else:
thread = threading.Thread(target=process_camera, args=(rtsp_urls[i], websocket_urls[i], None)) thread = threading.Thread(target=process_camera, args=(rtsp_urls[i], websocket_urls[i], None))
thread.start() thread.start()