我正在尝试从所需持续时间的麦克风中记录音频。我想通过获取用户输入来控制文件的持续时间。基于其决定,我必须停止记录并保存该持续时间的文件。
import pyaudio
import wave
from multiprocessing import Process
global flag
global frames
def try_recording(stream,RATE, CHUNK):
while flag != 1:
#for i in range(0,int(RATE/CHUNK*DURATION):
for i in range(0,int(RATE/CHUNK)):
data = stream.read(CHUNK)
frames.append(data)
def scan_input():
num = input('Enter input number: ')
if int(num) == 1:
flag = 1
else:
scan_input()
if __name__=='__main__':
FORMAT = pyaudio.paInt16
CHANNELS = 2
RATE = 44100
CHUNK = 1024
WAVE_OUTPUT_FILENAME = "file.wav"
flag = 0
audio = pyaudio.PyAudio()
# start Recording
stream = audio.open(format=FORMAT, channels=CHANNELS,
rate=RATE, input=True,
frames_per_buffer=CHUNK)
print("recording...")
frames = []
#sys.setrecursionlimit(1500)
p1 = Process(target=try_recording, args = (stream,RATE,CHUNK))
p1.start()
p2 = Process(target=scan_input)
p2.start()
#frames = try_recording(stream, RATE, CHUNK)
print('finished recording')
# stop Recording
stream.stop_stream()
stream.close()
audio.terminate()
waveFile = wave.open(WAVE_OUTPUT_FILENAME, 'wb')
waveFile.setnchannels(CHANNELS)
waveFile.setsampwidth(audio.get_sample_size(FORMAT))
waveFile.setframerate(RATE)
waveFile.writeframes(b''.join(frames))
waveFile.close()
当我在几秒钟内定义时间时,我能够记录文件。现在,我想在停止录制时扫描用户端的输入。因此,我通过添加并行处理来修改程序,以使两个函数同时运行。当我遇到递归错误时,我尝试通过添加sys.setrecursionlimit(1500)
来解决它,但结果不会改变任何内容。
如何解决问题,以便我可以在所需的持续时间内记录音频。
更新:错误和追溯
recording...
Traceback (most recent call last):
File "D:/Projects/Trails/try.py", line 14, in try_recording
try_recording(stream,RATE,CHUNK)
File "D:/Projects/Trails/try.py", line 14, in try_recording
try_recording(stream,RATE,CHUNK)
File "D:/Projects/Trails/try.py", line 14, in try_recording
try_recording(stream,RATE,CHUNK)
[Previous line repeated 995 more times]
File "D:/Projects/Trails/try.py", line 9, in try_recording
if flag == 1:
RecursionError: maximum recursion depth exceeded in comparison
如果我将限制增加到44000 sys.setrecursionlimit(44000)
代码运行约1秒,以错误
Process finished with exit code -1073741571 (0xC00000FD)
update2: @Quamrana建议的更新代码。
这两个过程无法同时工作。循环不在过程2功能之外。使用打印语句的测试我知道,直到我按1循环1在过程1中循环,后来它将移至第二个过程,但无法从第一个功能扫描输入以结束录制。
更新3:更新过程参数
Traceback (most recent call last):
File "D:/Projects/Trails/try.py", line 42, in <module>
p1.start()
File "C:Program FilesPython36libmultiprocessingprocess.py", line 105, in start
self._popen = self._Popen(self)
File "C:Program FilesPython36libmultiprocessingcontext.py", line 223, in _Popen
return _default_context.get_context().Process._Popen(process_obj)
File "C:Program FilesPython36libmultiprocessingcontext.py", line 322, in _Popen
return Popen(process_obj)
File "C:Program FilesPython36libmultiprocessingpopen_spawn_win32.py", line 65, in __init__
reduction.dump(process_obj, to_child)
File "C:Program FilesPython36libmultiprocessingreduction.py", line 60, in dump
ForkingPickler(file, protocol).dump(obj)
TypeError: can't pickle _portaudio.Stream objects
Traceback (most recent call last):
File "<string>", line 1, in <module>
File "C:Program FilesPython36libmultiprocessingspawn.py", line 105, in spawn_main
exitcode = _main(fd)
File "C:Program FilesPython36libmultiprocessingspawn.py", line 115, in _main
self = reduction.pickle.load(from_parent)
EOFError: Ran out of input
如何解决多处理泡菜错误?
我认为您实际上不需要try_recording
是递归的,因此可以像这样重写:
def try_recording(stream,RATE, CHUNK):
while flag != 1:
for i in range(0,int(RATE/CHUNK)):
data = stream.read(CHUNK)
frames.append(data)
您也无法正确启动流程。他们应该是:
p1 = Process(target=try_recording, args=(stream,RATE,CHUNK))
p2 = Process(target=scan_input)
,您的标志应该是共享变量:
# flag = 0
flag = multiprocessing.Value('i', 0)
try_recording
进入else
,您期望如何更新flag
。您在此处实施了任何IPC机制。导致它进入无限环