使用的是MySQL数据库
需要使用mysql-connector-python库来连接MySQL数据库。首先，请确保你已经安装了这个库，如果没有安装，可以通过以下命令安装：
pip install mysql-connector-python
假设：
- MySQL数据库已经配置好，并且有一个名为
live_streams的表，其中包含至少两列：id和stream_url。 - 我们需要检查每个URL是否可以正常访问，这里我们将使用
requests库来发送HTTP请求。
步骤：
- 连接到MySQL数据库。
- 获取直播流信息。
- 检查每个URL的可用性。
- 输出结果。
以下是Python脚本的代码：
import mysql.connector
import requests
def check_stream(stream_url):
try:
response = requests.get(stream_url, timeout=5)
if response.status_code == 200:
return True
else:
return False
except requests.RequestException:
return False
def main():
# 数据库连接参数
config = {
'user': 'your_username',
'password': 'your_password',
'host': 'your_host',
'database': 'your_database'
}
# 连接到MySQL数据库
conn = mysql.connector.connect(**config)
cursor = conn.cursor(dictionary=True)
# 查询所有直播流
query = "SELECT id, stream_url FROM live_streams"
cursor.execute(query)
rows = cursor.fetchall()
for row in rows:
stream_id = row['id']
stream_url = row['stream_url']
is_available = check_stream(stream_url)
print(f"Stream ID: {stream_id}, URL: {stream_url}, Available: {is_available}")
# 如果你想在数据库中记录状态，可以使用以下代码：
# update_query = "UPDATE live_streams SET available = %s WHERE id = %s"
# cursor.execute(update_query, (is_available, stream_id))
# conn.commit()
# 关闭数据库连接
cursor.close()
conn.close()
if __name__ == "__main__":
main()
注意事项：
- 替换
config字典中的数据库连接参数以匹配你的MySQL数据库设置。 - 如果你需要更新数据库中的状态，请取消注释相应的更新语句。
- 脚本中的超时设置为5秒，你可以根据需要调整这个值。
- 这个脚本假设所有的直播流都是通过HTTP协议提供的。如果使用其他协议（如RTMP等），则需要使用不同的方法来检查流的可用性。
