python实现实时视频流播放代码实例
作者:前方、有光 发布时间:2021-09-11 21:11:22
标签:python,实时,视频,流,播放
这篇文章主要介绍了python实现实时视频流播放代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
@action(methods=['GET'], detail=True)
def video(self, request, pk=None):
"""
获取设备实时视频流
:param request:
:param pk:
:return:
"""
device_obj = self.get_object()
# if device_obj.status == 0:
# return Response({'error': '设备离线'})
if not device_obj.rtsp_address:
return Response({'error': '缺少rtsp地址'})
cache_id = '_video_stream_{}'.format(device_obj.hash)
cache_status = cache.get(cache_id, None)
if cache_status is None: # 任务初始化,设置初始时间
cache.set(cache_id, time.time(), timeout=60)
elif isinstance(cache_status, float) and time.time() - cache_status > 30: # 任务已超时, 返回错误信息, 一段时间内不再入队
return Response({'error': '连接数目超过限制, 请稍后再试'})
ret = job_queue.enqueue_video(rtsp_address=device_obj.rtsp_address, device_hash=device_obj.hash)
logger.info('fetch device %s video job status: %s', pk, ret._status)
if ret._status == b'started' or 'started': # 视频流正常推送中, 刷新播放时间, 返回视频ID
cache.set(cache_id, 'continue', timeout=30)
return Response({'video': ''.join([settings.FFMPEG_VIDEO, device_obj.hash])})
elif ret._status == b'queued' or 'queued': # 视频任务等待中
return Response({'status': '等待建立视频连接'})
else: # 建立视频任务失败
return Response({'error': '打开视频失败'})
class JobQueue:
"""实时视频播放"""
def __init__(self):
self.video_queue = django_rq.get_queue('video') # 视频推流消息队列
def enqueue_video(self, rtsp_address, device_hash):
"""视频流队列"""
job_id = 'video_{}'.format(device_hash)
job = self.video_queue.fetch_job(job_id)
if not job:
job = self.video_queue.enqueue_call(
func='utils.ffmpeg.ffmpeg_play',
args=(rtsp_address, device_hash),
timeout=-1,
ttl=30, # 最多等待30秒
result_ttl=0,
job_id=job_id
)
return job
# -*- coding: utf-8 -*-
import subprocess
import threading
import time
import logging
from django.core.cache import cache
logger = logging.getLogger('server.default')
def ffmpeg_play(stream, name):
play = True
cache_id = '_video_stream_{}'.format(name)
cache.set(cache_id, 'continue', timeout=30)
process = None
def upstream():
cmd = "ffmpeg -i '{}' -c:v h264 -f flv -r 25 -an 'rtmp://127.0.0.1:1935/live/{}'".format(stream, name)
process = subprocess.Popen(cmd, shell=True, stdin=subprocess.PIPE, stderr=subprocess.DEVNULL)
try:
logger.info('device: {} stream thread start: {}'.format(name, stream))
while play:
time.sleep(1)
except Exception as e:
logger.info('device: {} stream thread error {}'.format(name, e))
finally:
logger.info('device: {} stream thread stop'.format(name))
process.communicate(b'q')
thr = threading.Thread(target=upstream)
thr.start()
try:
while True:
play = cache.get(cache_id, '')
if play != 'continue':
logger.info('stop device {} video stream'.format(name))
play = False
break
time.sleep(1)
except Exception as e:
logger.info('device: {} play stream error {}'.format(name, e))
process.communicate(b'q')
logger.info('wait device {} video thread stop'.format(name))
thr.join()
logger.info('device {} video job stop'.format(name))
# 实时视频流播放
RQ_QUEUES = {
'video': {
'USE_REDIS_CACHE': 'video',
}
}
来源:https://www.cnblogs.com/52-qq/p/11812430.html
0
投稿
猜你喜欢
- Python 风格规范(Google)本项目并非 Google 官方项目, 而是由国内程序员凭热情创建和维护。如果你关注的是 Google
- 核心代码:#!/usr/bin/python# -*- coding: UTF-8 -*-import smtplibimport osim
- 手痒痒系列之简单的放大镜写了个放大镜功能,可以设置显示的宽高width,height显示的位置,float ‘left’ 'righ
- MySQL使用环境变量TMPDIR的值作为保存临时文件的目录的路径名。如果未设置TMPDIR,MySQL将使用系统的默认值,通常为/tmp、
- 之前在懒懒分会上分享的一点关于border画小图的内容, 完整的ppt在这里.原理css盒模型一个盒子包括: margin+border+p
- 在我们完成一个Python项目或一个程序时,希望将Python的py文件打包成在Windows系统下直接可以运行的exe程序。在浏览网上的资
- 初学OpenCV图像处理的小伙伴肯定对什么高斯函数、滤波处理、阈值二值化等特性非常头疼,这里给各位分享一个小项目,可通过摄像头实时动态查看各
- 1.什么是Pillow首先我们需要了解一下PIL(Python Imaging Library),它是Python2中非常强大的图像处理标准
- 我就废话不多说了,大家还是直接看代码吧~# 导入pptx包from pptx import Presentationprs = Presen
- 代码示例1(8位)import randomimport stringtotal = string.ascii_letters + stri
- numpy的np.fromfile会出现如下的问题,只能一次性读取文件的内容,不能追加读取,连续两次的np.fromfile读到的东西一样如
- 本文以YOLOv5-6.1版本为例一、Add1.在common.py后加入如下代码# 结合BiFPN 设置可学习参数 学习不同分支的权重#
- 实例如下所示:>>>from compiler.ast import flatten>>>Xmatrix
- <html><body><table border=1> <? $id=@mssql_connec
- 前言将字符串动态转换为DOM节点,在开发中经常遇到,尤其在模板引擎中更是不可或缺的技术。字符串转换为DOM节点本身并不难,本篇文章主要涉
- 前言本文紧接着前一篇的入门教程,会介绍一些关于pandas的进阶知识。建议读者在阅读本文之前先看完pandas入门教程。同样的,本文的测试数
- 1.简介torch.autograd.Variable是Autograd的核心类,它封装了Tensor,并整合了反向传播的相关实现Varia
- 本文实例讲述了CI操作cookie的方法。分享给大家供大家参考,具体如下:CI 操作cookie 有三种方法,2中Ci自带的,其
- 揭秘一个普通的输入框背后惊人的秘密。某月某日,某项目某页面,需要一个价格区间筛选功能,需求合理,所以设计做上去。这是一个无比普通的输入框。在
- 先导入模块:from django.core.paginator import Paginator, EmptyPage, PageNotA