add class AudioTransformTrack(MediaStreamTrack):

[LogWell]

How to implement AudioTransformTrack like VideoTransformTrack in https://github.com/aiortc/aiortc/blob/main/examples/server/server.py#L22

You should add

import numpy as np
from av import AudioFrame

and replace https://github.com/aiortc/aiortc/blob/main/examples/server/server.py#L141 with

pc.addTrack(
    AudioTransformTrack(
        relay.subscribe(player.audio)
    )
)

The following code is NG except uncomment # return frame #! OK

class AudioProcessingTrack(MediaStreamTrack):
    kind = "audio"

    def __init__(self, track):
        super().__init__()  
        self.track = track

    async def recv(self):
        frame = await self.track.recv()
        new_frame = await self.process(frame)
        return new_frame

    async def process(self, frame):
        # return frame  #! OK
        gain = 1.5
        for p in frame.planes:
            samples = np.frombuffer(p.to_bytes(), dtype=np.int16)
            samples = np.clip(samples * gain, -32768, 32767)
            p.update(samples.tobytes())
        
        new_frame = AudioFrame(format=frame.format, layout=frame.layout, samples=frame.samples)
        new_frame.pts = frame.pts
        new_frame.sample_rate = frame.sample_rate
        new_frame.time_base = frame.time_base
        return new_frame

[gg22mm]

我试了，想用队列输出声音不行

class diyKindAudio(MediaStreamTrack):   

    kind = "audio"

    def __init__(self):
        super().__init__() #必须初始化 VideoStreamTrack   
        self.cap = audio_queue  #cv2.VideoCapture(0, cv2.CAP_DSHOW) #本地摄像头        

    async def recv(self):
        audio_frame = audio_queue.get(timeout=1)  # 从音频队列中取样本
        print(f"------音频帧 Audio data shape: {audio_frame.shape}")
        
        if not audio_frame:
            raise Exception("--音频队列为空--")
        
        # 2、推流声音  
        frame = audio_frame.astype(np.int16)         
        new_frame = AudioFrame(format='s16', layout='mono', samples=frame.shape[0]) # 创建一个单声道，采样率为44100Hz的AudioFrame  
        new_frame.planes[0].update(frame.tobytes()) # __video_frame_buffer=frame.tobytes()
        new_frame.sample_rate=24000 #原来：16000 
        return new_frame