pref: 删除标注页面信息栏, 减小摄像头采集分辨率
This commit is contained in:
24
cam_cap.py
24
cam_cap.py
@@ -82,10 +82,10 @@ def capture_thread():
|
||||
cam_right = cv2.VideoCapture('/dev/videoR')
|
||||
|
||||
# # 设置摄像头分辨率
|
||||
cam_left.set(cv2.CAP_PROP_FRAME_WIDTH, 1280)
|
||||
cam_left.set(cv2.CAP_PROP_FRAME_HEIGHT, 720)
|
||||
cam_right.set(cv2.CAP_PROP_FRAME_WIDTH, 1280)
|
||||
cam_right.set(cv2.CAP_PROP_FRAME_HEIGHT, 720)
|
||||
cam_left.set(cv2.CAP_PROP_FRAME_WIDTH, 640)
|
||||
cam_left.set(cv2.CAP_PROP_FRAME_HEIGHT, 480)
|
||||
cam_right.set(cv2.CAP_PROP_FRAME_WIDTH, 640)
|
||||
cam_right.set(cv2.CAP_PROP_FRAME_HEIGHT, 480)
|
||||
|
||||
while True:
|
||||
ret_left, frame_left = cam_left.read()
|
||||
@@ -104,20 +104,20 @@ def capture_thread():
|
||||
cam_right.release()
|
||||
|
||||
async def send_image_to_web_server(frame_left, frame_right, metadata):
|
||||
"""异步发送图片到Web服务器(留空实现)"""
|
||||
"""异步发送图片到 Web 服务器(留空实现)"""
|
||||
try:
|
||||
# 编码为JPEG
|
||||
# 编码为 JPEG
|
||||
_, jpeg_left = cv2.imencode('.jpg', frame_left)
|
||||
_, jpeg_right = cv2.imencode('.jpg', frame_right)
|
||||
jpeg_left = jpeg_left.tobytes()
|
||||
jpeg_right = jpeg_right.tobytes()
|
||||
|
||||
# HTTP POST请求实现留空
|
||||
# HTTP POST 请求实现留空
|
||||
print(f"Would send frame {metadata['timestamp']} to web server via HTTP POST")
|
||||
# print(f"Client ID: {metadata['client_id']}")
|
||||
cv2.imwrite(f"./saved/left_{metadata['timestamp']}.jpg", frame_left)
|
||||
cv2.imwrite(f"./saved/right_{metadata['timestamp']}.jpg", frame_right)
|
||||
# 这里可以添加实际的HTTP POST请求代码
|
||||
# 这里可以添加实际的 HTTP POST 请求代码
|
||||
# 示例:
|
||||
async with aiohttp.ClientSession() as session:
|
||||
data = aiohttp.FormData()
|
||||
@@ -143,7 +143,7 @@ class ImageServer:
|
||||
self.socket = None
|
||||
|
||||
async def handle_client_request(self, client_id):
|
||||
"""处理客户端请求:获取最新帧并发送到Web服务器"""
|
||||
"""处理客户端请求:获取最新帧并发送到 Web 服务器"""
|
||||
try:
|
||||
# 从缓冲区获取最新帧
|
||||
frame_left, frame_right = image_buffer.get_latest_frames()
|
||||
@@ -158,7 +158,7 @@ class ImageServer:
|
||||
# }
|
||||
}
|
||||
|
||||
# 异步发送图片到Web服务器
|
||||
# 异步发送图片到 Web 服务器
|
||||
asyncio.create_task(send_image_to_web_server(frame_left, frame_right, metadata))
|
||||
|
||||
logger.info(f"Processed request from client {client_id}, frames sent to web server")
|
||||
@@ -179,10 +179,10 @@ class ImageServer:
|
||||
|
||||
while True:
|
||||
try:
|
||||
# 接收客户端请求(客户端ID)
|
||||
# 接收客户端请求(客户端 ID)
|
||||
data = await self.socket.arecv()
|
||||
|
||||
# 解析客户端ID
|
||||
# 解析客户端 ID
|
||||
client_id = data.decode('utf-8') if data else "unknown"
|
||||
# logger.info(f"Received request from client: {client_id}")
|
||||
|
||||
|
||||
Reference in New Issue
Block a user