Как передать аудиоданные потоком через сокет?

Question

[Dobroe3lo]

Всем доброго времени суток. Помогите, пожалуйста, в одном вопросе.

Пытаюсь на питоне реализовать передачу аудиоданных в потоке через сокет.
Как сделать, чтобы аудиофайл в сокет отправлялся порциями(по байтам)? Между порциями аудио в сокет должен отправляться разделитель "--audio".

Использую библиотеку PyAudio

Вот код целиком. При отладке сокет открывается, api запрос отправляется и по факту стрим должен начаться, но вылетает ошибка.

#######Подключаемые модули

import requests
import socket
import pyaudio
import wave


##########################

#######Открываем сокет для стрима
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect(('192.168.13.122', 80))

#######Передаем API запросы по HTTP POST
url = 'http://192.168.13.122/cgi-bin/transmitaudio_cgi?user=admin&pwd=admin HTTP'
headers = {'Content-Type': 'audio/basic', 'Content-Length': '99999999', 'Connection': 'Keep-Alive', 'Cache-Control': 'no-cache'}
r = requests.post(url, headers=headers)
print(requests.__file__)
print(dir(requests))

#######Транслируем звук

filename = 'voice.wav'

# Set chunk size of 1024 samples per data frame
chunk = 1024  

# Open the sound file 
wf = wave.open(filename, 'rb')

# Create an interface to PortAudio
p = pyaudio.PyAudio()

# Open a .Stream object to write the WAV file to
# 'output = True' indicates that the sound will be played rather than recorded
stream = p.open(format = p.get_format_from_width(wf.getsampwidth()),
                channels = wf.getnchannels(),
                rate = wf.getframerate(),
                output = True)

# Read data in chunks
data = wf.readframes(chunk)

# Play the sound by writing the audio data to the stream
while data != '':
    stream.write(data)
    data = wf.readframes(chunk)

# Close and terminate the stream
stream.close()
p.terminate()

sock.close()

Ошибка

Traceback (most recent call last):
  File "C:\Users\Roman\Desktop\ПО HTTP Audio\cgiaudio.py", line 30, in <module>
    wf = wave.open(filename, 'rb')
  File "C:\Users\Roman\AppData\Local\Programs\Python\Python37\lib\wave.py", line 510, in open
    return Wave_read(f)
  File "C:\Users\Roman\AppData\Local\Programs\Python\Python37\lib\wave.py", line 164, in __init__
    self.initfp(f)
  File "C:\Users\Roman\AppData\Local\Programs\Python\Python37\lib\wave.py", line 131, in initfp
    raise Error('file does not start with RIFF id')
wave.Error: file does not start with RIFF id.

Comments

[javedimka]

Зачем нужны извращения с pyaudio? Открыть файл в rb и пихать в сокет в соответствии с правилами не получается?

[Dobroe3lo]

javedimka, не могли бы вы помочь немного в реализации этого?

[javedimka]

Dobroe3lo,

import socket

CHUNK_SIZE = 1024

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect(('192.168.13.122', 80))

with open("my_audio.wav", "rb") as f:
    eof = False
    while True:
        chunk = f.read(CHUNK_SIZE)
        if chunk:
            if len(chunk) < CHUNK_SIZE:
                eof = True
            sock.sendall(chunk + b"--audio")
        else:
            break

        if eof:
            break

[Dobroe3lo]

javedimka, программа отрабатывает, но аудио всеравно не проигрывается.
Пытаюсь передать аудио со след. характеристиками: битрейт-8бит, частота дискретизации-8000гц.
Мне нужно отправить аудиопоток с той же скорость, с какой он воспроизводится.

P.S после отладки вылетает следующее (вроде не ошибка):

C:\Users\Roman\AppData\Local\Programs\Python\Python37\lib\site-packages\requests\__init__.py
['ConnectTimeout', 'ConnectionError', 'DependencyWarning', 'FileModeWarning', 'HTTPError', 'NullHandler', 'PreparedRequest', 'ReadTimeout', 'Request', 'RequestException', 'RequestsDependencyWarning', 'Response', 'Session', 'Timeout', 'TooManyRedirects', 'URLRequired', '__author__', '__author_email__', '__build__', '__builtins__', '__cached__', '__cake__', '__copyright__', '__description__', '__doc__', '__file__', '__license__', '__loader__', '__name__', '__package__', '__path__', '__spec__', '__title__', '__url__', '__version__', '_check_cryptography', '_internal_utils', 'adapters', 'api', 'auth', 'certs', 'chardet', 'check_compatibility', 'codes', 'compat', 'cookies', 'delete', 'exceptions', 'get', 'head', 'hooks', 'logging', 'models', 'options', 'packages', 'patch', 'post', 'put', 'request', 'session', 'sessions', 'status_codes', 'structures', 'urllib3', 'utils', 'warnings']

[javedimka]

Dobroe3lo, Что есть аудиопоток?
Что значит с той же скорость с которой он воспроизводится?
Куда надо передавать?