From 674be3442c5936db4ad166a278cd13f30be54621 Mon Sep 17 00:00:00 2001 From: frxz751113 <156018267+frxz751113@users.noreply.github.com> Date: Mon, 19 Aug 2024 19:58:41 +0800 Subject: [PATCH] =?UTF-8?q?Update=20IP=E6=9B=B4=E6=96=B0.py?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- py/IP更新.py | 198 ++------------------------------------------------- 1 file changed, 7 insertions(+), 191 deletions(-) diff --git a/py/IP更新.py b/py/IP更新.py index ab4c730..3b4e4dc 100644 --- a/py/IP更新.py +++ b/py/IP更新.py @@ -2,6 +2,10 @@ import requests import re import cv2 # 导入OpenCV库 + +#本段代码更新文件方式-----追加写入 +#同省份多城市查询IP + # 更新广东组播定义fofa链接列表 fofa_urls = [ 'https://fofa.info/result?qbase64=InVkcHh5IiAmJiBjaXR5PSJmb3NoYW4i', # 佛山市 @@ -77,7 +81,7 @@ if valid_ips_ports: for valid_ip_port in valid_ips_ports: print(valid_ip_port) # 指定需要更新的本地文件路径 - local_file_path = '广东电信.txt' + local_file_path = 'playlist/广东电信.txt' # 更新文件中的IP地址并将每个IP写入新行 update_and_write_ips(local_file_path, valid_ips_ports) else: @@ -159,7 +163,7 @@ if valid_ips_ports: for valid_ip_port in valid_ips_ports: print(valid_ip_port) # 指定需要更新的本地文件路径 - local_file_path = '四川电信.txt' + local_file_path = 'playlist/四川电信.txt' # 更新文件中的IP地址并将每个IP写入新行 update_and_write_ips(local_file_path, valid_ips_ports) else: @@ -243,7 +247,7 @@ if valid_ips_ports: for valid_ip_port in valid_ips_ports: print(valid_ip_port) # 指定需要更新的本地文件路径 - local_file_path = '湖北电信.txt' + local_file_path = 'playlist/湖北电信.txt' # 更新文件中的IP地址并将每个IP写入新行 update_and_write_ips(local_file_path, valid_ips_ports) else: @@ -251,192 +255,4 @@ else: -fofa_url = 'https://fofa.info/result?qbase64=InVkcHh5IiAmJiByZWdpb249IkhlYmVpIg%3D%3D' #河北 -# 尝试从fofa链接提取IP地址和端口号，并去除重复项 -def extract_unique_ip_ports(fofa_url): - try: - response = requests.get(fofa_url, timeout=13) - html_content = response.text - # 使用正则表达式匹配IP地址和端口号 - ips_ports = re.findall(r'(\d+\.\d+\.\d+\.\d+:\d+)', html_content) - unique_ips_ports = list(set(ips_ports)) # 去除重复的IP地址和端口号 - return unique_ips_ports if unique_ips_ports else None - except requests.RequestException as e: - print(f"请求错误: {e}") - return None -# 检查视频流的可达性 -def check_video_stream_connectivity(ip_port, urls_udp): - try: - # 构造完整的视频URL - video_url = f"http://{ip_port}{urls_udp}" - # 用OpenCV读取视频 - cap = cv2.VideoCapture(video_url) - - # 检查视频是否成功打开 - if not cap.isOpened(): - print(f"视频URL {video_url} 无效") - return None - else: - # 读取视频的宽度和高度 - width = int(cap.get(cv2.CAP_PROP_FRAME_WIDTH)) - height = int(cap.get(cv2.CAP_PROP_FRAME_HEIGHT)) - print(f"视频URL {video_url} 的分辨率为 {width}x{height}") - # 检查分辨率是否大于0 - if width > 0 and height > 0: - return ip_port # 返回有效的IP和端口 - # 关闭视频流 - cap.release() - except Exception as e: - print(f"访问 {ip_port} 失败: {e}") - return None - -# 更新文件中的IP地址和端口号 -def update_files(accessible_ip_port, files_to_update): - for file_info in files_to_update: - try: - # 读取原始文件内容 - response = requests.get(file_info['url']) - file_content = response.text - - # 替换文件中的IP地址和端口号 - # 假设文件中的IP地址和端口号格式为 http://IP:PORT - ip_port_pattern = r'(http://\d+\.\d+\.\d+\.\d+:\d+)' - updated_content = re.sub(ip_port_pattern, f'http://{accessible_ip_port}', file_content) - - # 保存更新后的内容到新文件 - with open(file_info['filename'], 'w', encoding='utf-8') as file: - file.write(updated_content) - - print(f"文件 {file_info['filename']} 已更新并保存。") - except requests.RequestException as e: - print(f"无法更新文件 {file_info['filename']}，错误: {e}") - -# 定义组播地址和端口 -urls_udp = "/udp/239.254.200.45:8008" - -# 提取唯一的IP地址和端口号 -unique_ips_ports = extract_unique_ip_ports(fofa_url) - -if unique_ips_ports: - print("提取到的唯一IP地址和端口号：") - for ip_port in unique_ips_ports: - print(ip_port) - - # 测试每个IP地址和端口号，直到找到一个可访问的视频流 - valid_ip = None - for ip_port in unique_ips_ports: - valid_ip = check_video_stream_connectivity(ip_port, urls_udp) - if valid_ip: - break # 找到有效的IP后，不再继续循环 - - if valid_ip: - print(f"找到可访问的视频流服务: {valid_ip}") - # 定义需要更新的文件列表 - files_to_update = [ - {'url': 'https://raw.githubusercontent.com/frxz751113/IPTVzb/main/河北电信.txt', 'filename': '河北电信.txt'} #, - #{'url': 'https://raw.githubusercontent.com/frxz751113/IPTVzb/main/广东电信.m3u', 'filename': '广东电信.m3u'} - ] - - # 更新文件中的IP地址和端口号 - update_files(valid_ip, files_to_update) - else: - print("没有找到可访问的视频流服务。") -else: - print("没有提取到IP地址和端口号。") - - - -fofa_url = 'https://fofa.info/result?qbase64=InVkcHh5IiAmJiByZWdpb249Ikh1bmFuIg%3D%3D' #湖南 -# 尝试从fofa链接提取IP地址和端口号，并去除重复项 -def extract_unique_ip_ports(fofa_url): - try: - response = requests.get(fofa_url, timeout=13) - html_content = response.text - # 使用正则表达式匹配IP地址和端口号 - ips_ports = re.findall(r'(\d+\.\d+\.\d+\.\d+:\d+)', html_content) - unique_ips_ports = list(set(ips_ports)) # 去除重复的IP地址和端口号 - return unique_ips_ports if unique_ips_ports else None - except requests.RequestException as e: - print(f"请求错误: {e}") - return None - -# 检查视频流的可达性 -def check_video_stream_connectivity(ip_port, urls_udp): - try: - # 构造完整的视频URL - video_url = f"http://{ip_port}{urls_udp}" - # 用OpenCV读取视频 - cap = cv2.VideoCapture(video_url) - - # 检查视频是否成功打开 - if not cap.isOpened(): - print(f"视频URL {video_url} 无效") - return None - else: - # 读取视频的宽度和高度 - width = int(cap.get(cv2.CAP_PROP_FRAME_WIDTH)) - height = int(cap.get(cv2.CAP_PROP_FRAME_HEIGHT)) - print(f"视频URL {video_url} 的分辨率为 {width}x{height}") - # 检查分辨率是否大于0 - if width > 0 and height > 0: - return ip_port # 返回有效的IP和端口 - # 关闭视频流 - cap.release() - except Exception as e: - print(f"访问 {ip_port} 失败: {e}") - return None - -# 更新文件中的IP地址和端口号 -def update_files(accessible_ip_port, files_to_update): - for file_info in files_to_update: - try: - # 读取原始文件内容 - response = requests.get(file_info['url']) - file_content = response.text - - # 替换文件中的IP地址和端口号 - # 假设文件中的IP地址和端口号格式为 http://IP:PORT - ip_port_pattern = r'(http://\d+\.\d+\.\d+\.\d+:\d+)' - updated_content = re.sub(ip_port_pattern, f'http://{accessible_ip_port}', file_content) - - # 保存更新后的内容到新文件 - with open(file_info['filename'], 'w', encoding='utf-8') as file: - file.write(updated_content) - - print(f"文件 {file_info['filename']} 已更新并保存。") - except requests.RequestException as e: - print(f"无法更新文件 {file_info['filename']}，错误: {e}") - -# 定义组播地址和端口 -urls_udp = "/udp/239.76.253.151:9000" - -# 提取唯一的IP地址和端口号 -unique_ips_ports = extract_unique_ip_ports(fofa_url) - -if unique_ips_ports: - print("提取到的唯一IP地址和端口号：") - for ip_port in unique_ips_ports: - print(ip_port) - - # 测试每个IP地址和端口号，直到找到一个可访问的视频流 - valid_ip = None - for ip_port in unique_ips_ports: - valid_ip = check_video_stream_connectivity(ip_port, urls_udp) - if valid_ip: - break # 找到有效的IP后，不再继续循环 - - if valid_ip: - print(f"找到可访问的视频流服务: {valid_ip}") - # 定义需要更新的文件列表 - files_to_update = [ - {'url': 'https://raw.githubusercontent.com/frxz751113/IPTVzb/main/湖南电信.txt', 'filename': '湖南电信.txt'} #, - #{'url': 'https://raw.githubusercontent.com/frxz751113/IPTVzb/main/广东电信.m3u', 'filename': '广东电信.m3u'} - ] - - # 更新文件中的IP地址和端口号 - update_files(valid_ip, files_to_update) - else: - print("没有找到可访问的视频流服务。") -else: - print("没有提取到IP地址和端口号。")