条件を１秒間満たし続けたらforから抜けたい

Question

#質問内容
python3でpyaudioを用いて、音声を録音するプログラムを制作しています。

録音レベル(変数xmax)がしきい値（変数threshold）を上回ると録音が開始されるようになっているのですが、
録音レベル(変数xmax)がしきい値（変数threshold）を１秒間下回り続けたら（または録音開始後10秒たったら）録音を終了するようにしたいです。

つまり、次のプログラムで、変数xmax < 変数threshold の状態が１秒間続いたらfor構文から抜けるようにしたいのです。

#プログラム抜粋

if xmax > threshold: #録音レベルがしきい値を上回ったら
	for i in range(0, int(A)):
		data = stream.read(chunk)
		all.append(data)
#int(A)は10秒分の長さ（おそらく）

どのように記述すればよいのかわからず困っています。
どうすれば良いのでしょうか？

#プログラム全体

# -*- coding: utf-8 -*-
#マイク0番からの入力を受ける。録音し、保存する。
 
import pyaudio
import sys
import time
import wave
import requests
import os
import json
import numpy as np

def recognize_rec():
	chunk = 1024
	FORMAT = pyaudio.paInt16
	CHANNELS = 1
	
	CARD = 1 #OUTPUTの指定
	DEVICE = 0 #OUTPUTの指定

	
	PATH = '/var/tmp/tmp.wav'
	
	#しきい値。これを超えると録音を開始する。
	threshold = 0.15 #しきい値
	
	#サンプリングレート、マイク性能に依存
	RATE = 16000
	
	#録音時間の上限
	RECORD_SECONDS = 10

	#pyaudio
	p = pyaudio.PyAudio()
	#マイク0番を設定
	input_device_index = 0
	#マイクからデータ取得
	stream = p.open(format = FORMAT,
					channels = CHANNELS,
					rate = RATE,
					input = True,
					frames_per_buffer = chunk)

	all = []

	A = int(RATE) / int(chunk) * int(RECORD_SECONDS)
		
	print("RATE = " + str(RATE))
	print("chunk = " + str(chunk))
	print("RECORD_SECONDS = " + str(RECORD_SECONDS))
	print("RATE / chunk * RECORD_SECONDS = " + str(A))
	print("")
	
	while True:
		data = stream.read(chunk)
		x = np.frombuffer(data, dtype="int16") / 32768.0
		
		#まずサンプルを取る！
		xmax = x.max()
				
		if xmax > threshold: #録音レベルがしきい値を上回ったら
			for i in range(0, int(A)):　#←抜けたいfor構文！
				data = stream.read(chunk)
				all.append(data)
			data = b''.join(all)
					
			out = wave.open(PATH,'w')
			out.setnchannels(1) #mono
			out.setsampwidth(2) #16bits
			out.setframerate(RATE)
			out.writeframes(data)
			out.close()
			break
		
		
		#time.sleep(0.5)		 
	
	stream.close() 
	p.terminate()
	

if __name__ == '__main__':
	print(recognize_rec())

Answer 1

条件が成立したら、タイマなり時刻カウントなりを開始させ、１秒経過を検出すればいいです。
経過までに条件が不成立になれば、時刻カウントをリセットする、ということで

Answer 2

n個のchunkで連続して閾値を下回ったら、という条件だと次のように書けると思います。

#録音中断までの時間
STOP_SECONDS = 1  # [sec]
B = int(RATE / chunk * STOP_SECONDS)

if xmax > threshold: #録音レベルがしきい値を上回ったら
    n = 0  # 連続して閾値を下回った回数を記録するための変数

    for i in range(0, int(A)):
        data = stream.read(chunk)
        all.append(data)

        x = np.frombuffer(data, dtype="int16") / 32768.0
        xmax = x.max()
        if xmax <= threashold:
            # 閾値を下回っていたらincrementする
            n += 1
        else:
            # 閾値を上回ったらリセットする
            n = 0
        
        # 中断判定
        if n == B:
            break

Comments

[shirasu10fish]

上手くいきました。ありがとうございました。