touchscreen/StreamSetting.py at main · mat4133/touchscreen · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
from threading import Thread
from os.path import expanduser
import os
import time
import datetime
from multiprocessing import Process
import subprocess
import picamera
from picamera import PiCamera


flag = 0
def STOP():
    global flag
    flag = 1

def STOP_SCREEN():
    subprocess.call('pkill -n ffmpeg', shell=True)
    try:
        t.stop()
    except:
        print("")

def STREAM_CAMERA_COMMAND(FPS, VIDEOBUFFER, KEY, PLATFORM, AUDIO):
    global flag
    PiCamera().close()
    camera = picamera.PiCamera(resolution=(1280, 720), framerate=FPS)
    if AUDIO == 1:
        VOLUME = 0
    elif AUDIO == 0:
        VOLUME = 256
    if PLATFORM == 1:
        STREAMURL = 'rtmp://a.rtmp.youtube.com/live2/'
    elif PLATFORM == 0:
        STREAMURL = 'rtmps://live-api-s.facebook.com:443/rtmp/'
        KEY = "\"" + str(KEY) + "\""
    if VIDEOBUFFER >= 0:
        BUFFERAUDIO = VIDEOBUFFER
        BUFFERVIDEO = 0
    elif VIDEOBUFFER < 0:
        BUFFERAUDIO = 0
        BUFFERVIDEO = VIDEOBUFFER
    stream_pipe = subprocess.Popen(
        '/home/pi/FFmpeg-n4.1.3/ffmpeg -use_wallclock_as_timestamps 1 -thread_queue_size 32K -f h264 -r ' + str(FPS) + ' -itsoffset ' + str(BUFFERVIDEO) + ' -i - -f alsa -ar 16000 -itsoffset ' + str(BUFFERAUDIO) + ' -ac 1 -thread_queue_size 32K -i pulse -use_wallclock_as_timestamps 1 -vol ' + str(VOLUME) + ' -c:a aac -async 1 -filter:a "highpass=f=80, lowpass=f=8000" -c:v libx264 -preset ultrafast -f flv -r ' + str(FPS) + ' ' + str(STREAMURL) + str(KEY),
        stdin=subprocess.PIPE, shell=True)
    if flag == 0:
        camera.framerate = FPS
        camera.vflip = True
        camera.hflip = True
        camera.rotation = 90
        camera.start_recording(stream_pipe.stdin, format='h264')
        while True:
            if flag == 1:
                camera.stop_recording()
                camera.close()
                STOP_SCREEN()
                break
            camera.wait_recording(1)
    flag = 0


def STREAM_SCREEN_COMMAND(FPS, VIDEOBUFFER, KEY, PLATFORM, AUDIO):
    global flag
    if AUDIO == 1:
        VOLUME = 0
    elif AUDIO == 0:
        VOLUME = 256
    if PLATFORM == 1:
        STREAMURL = 'rtmp://a.rtmp.youtube.com/live2/'
    elif PLATFORM == 0:
        STREAMURL = 'rtmps://live-api-s.facebook.com:443/rtmp/'
        KEY = "\"" + str(KEY) + "\""
    if VIDEOBUFFER >= 0:
        BUFFERAUDIO = VIDEOBUFFER
        BUFFERVIDEO = 0
    elif VIDEOBUFFER < 0:
        BUFFERAUDIO = 0
        BUFFERVIDEO = VIDEOBUFFER
    stream_pipe = subprocess.Popen(
        '/home/pi/FFmpeg-n4.1.3/ffmpeg -use_wallclock_as_timestamps 1 -thread_queue_size 32k -f x11grab -s 310x200 -r ' + str(FPS) + ' -itsoffset ' + str(BUFFERVIDEO) + ' -i :0.0+5,35 -f alsa -use_wallclock_as_timestamps 1 -ac 1 -ar 16000 -thread_queue_size 32k -itsoffset ' + str(BUFFERAUDIO) + ' -i pulse -async 1 -c:v libx264 -c:a aac -filter:a "highpass=f=80, lowpass=f=8000" -pix_fmt yuv420p -qp 0 -preset ultrafast -r ' + str(FPS) + ' -vol ' + str(VOLUME) + ' -f flv ' + str(STREAMURL) + str(KEY),
        stdin=subprocess.PIPE, shell=True)