test-streaming.py

import json, base64, websocket

class Base64Encoder(json.JSONEncoder):
    
    def default(self, o):
        
        if isinstance(o, bytes): return base64.b64encode(o).decode()
        return json.JSONEncoder.default(self, o)
    
class Emitter:
    
    def __init__(self, streaming_url):
        
        self.url = streaming_url
        
    def send(self, filepath, chunk_size=2048):
        
        src = open(filepath, 'rb')
        wss = websocket.create_connection(self.url)
        # Send first event with initialization
        wss.send(json.dumps({'event': 'start', 'format': 'ulaw'}))
        # Send first packet
        chk = src.read(chunk_size)
        pkt = {'event': 'media', 'media': {'payload': chk}}
        wss.send(json.dumps(chk, cls=Base64Encoder))
        # Keep emitting packet until dried file
        while chk:
            chk = src.read(chunk_size)
            pkt = {'event': 'media', 'media': {'payload': chk}}
            wss.send(json.dumps(chk, cls=Base64Encoder))
        # Send conclusion event
        wss.send(json.dumps({'event': 'stop'}))
        # Close file and connection
        src.close()
        wss.close()