RTSP to UDP

import socket
import re
 
 
 
ip = "192.168.10.100"  
adr = "rtsp://admin:1234pass@192.168.10.100:554/h264/ch01/main/av_stream/"
sdp = """
v=0
o=- 0 0 IN IP4 192.168.10.100
s=RTP Stream
c=IN IP4 192.168.10.100
m=video 8001 RTP/AVP 96
a=rtpmap:96 H264/90000
"""
 
dest = ("DESCRIBE " + adr + " RTSP/1.0\r\nCSeq: 0\r\nUser-Agent: python\r\nAccept: application/sdp\r\nContent-Length: " + str(len(sdp)) + "\r\n\r\n" + sdp).encode()
setu = ("SETUP " + adr + "/trackID=1 RTSP/1.0\r\nCSeq: 1\r\nUser-Agent: python\r\nTransport: RTP/AVP;unicast;client_port=8001-8002\r\n\r\n").encode()
optio = ("OPTIONS " + adr + " RTSP/1.0\r\nCSeq: 2\r\nUser-Agent: python\r\n\r\n").encode()
play = ("PLAY " + adr + " RTSP/1.0\r\nCSeq: 3\r\nUser-Agent: python\r\nSession: SESID\r\nRange: npt=0.000-\r\n\r\n").encode()
 
 
def getPorts(searchst, st):
    pat = re.compile(searchst + "=\d*-\d*")
    pat2 = re.compile('\d+')
    mstring = pat.findall(st)[0]
    nums = pat2.findall(mstring)
    numas = []
    for num in nums:
        numas.append(int(num))
    return numas
 
 
def getLength(st):
    pat = re.compile("Content-Length: \d*")
    pat2 = re.compile('\d+')
    mstring = pat.findall(st)[0]
    num = int(pat2.findall(mstring)[0])
    return num
 
 
def printrec(recst):
    """ Красиво выводит строки RTSP """
    recs = (recst).decode().split('\r\n')
    for rec in recs:
        print(rec)
 
 
def sessionid(recst):
    """ Ищет идентификатор сессии в строках RTSP """
    recs = recst.decode().split('\r\n')
    for rec in recs:
        ss = rec.split()
        if ss[0].strip() == "Session:":
            return str(ss[1].split(";")[0].strip())
 
 
def setsesid(recst, idn):
    
    return (recst.replace("SESID", str(idn))).encode()
 
 
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((ip, 554))
print("\n*** ОТПРАВКА DESCRIBE ***\n")
s.send(dest)
recst = s.recv(2048)
printrec(recst)
print("\n*** ОТПРАВКА OPTIONS ***\n")
s.send(optio)
recst = s.recv(2048)
printrec(recst)
print("\n*** ОТПРАВКА SETUP ***\n")
s.send(setu)
recst = s.recv(2048)
printrec(recst)
idn = sessionid(recst)
serverports = getPorts("server_port", recst.decode())
clientports = getPorts("client_port", recst.decode())
print("\nip,serverports", ip, serverports)
 
print("\n*** ОТПРАВКА PLAY ***\n")
play = setsesid(play.decode(), idn)
s.send(play)
recst = s.recv(2048)
printrec(recst)
print("START SEND...")
 
 
 
 
 
try:
    
    s1 = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
    
    s1.bind(("", 8001))
    s1.settimeout(5)
    while True:
        
        recst = s1.recv(1536)
        if not recst:
            continue
        s1.sendto(recst, ('192.168.13.12', 4002))
        
 
 
except Exception as ex:
    print(ex)
    
s.close()
s1.close()