亚马逊转录Python API：事件处理程序仅在流结束后才处理音频

Question

（没有在AWS重新发布中得到答案，所以在这里尝试）

我将通过WebSocket从Web浏览器发送流音频数据作为Blob。在后端，我使用Django Channels的AsyncWebsocketConsumer接收它，然后将其发送到Amazon转录并尝试使用成绩单接近实时地回复浏览器。

我能够发送单个斑点的转录，但无法以流方式发送。我看到事件处理程序仅在流结束时才会触发，这使我思考，也许我错误地使用了异步或转录API。

除了下面的代码外，我到目前为止尝试过的是：

为每个音频块创建一个单独的流。错误Amazon_Transcribe.Exceptions.InternalFailureException：发生了内部错误。被扔了。

1. 使用的asyncio.gather函数 stream.input_stream.send_audio_event函数和 Handler.handle_events函数。处理程序没有被调用。
2. 使用的asyncio.create_task（Handler.handle_events）创建一个 处理程序的非阻滞任务。处理程序没有被调用，并且 另外，它没有等待15秒。任务完成了 立即地。

stream_client = TranscribeStreamingClient(region="us-west-2")

class AWSTranscriptHandler(TranscriptResultStreamHandler):
    def __init__(self, transcript_result_stream):
        self.channel_layer = get_channel_layer()
        self.channel_name = "test"
        super().__init__(transcript_result_stream)

    async def handle_transcript_event(self, transcript_event: TranscriptEvent):
        results = transcript_event.transcript.results
        for result in results:
            if not (result.is_partial):
                for alt in result.alternatives:
                    await self.channel_layer.send(
                        self.channel_name,
                        {"type": "send_transcript", "message": alt.transcript},
                    )


class ChatConsumer(AsyncWebsocketConsumer):
    async def connect(self):
        await self.accept()
        await self.send(
            text_data=json.dumps(
                {"type": "connection_established", "channel_name": self.channel_name}
            )
        )
        self.stream = await stream_client.start_stream_transcription(
            language_code="en-US",
            media_sample_rate_hz=48000,
            media_encoding="ogg-opus",
        )
        self.handler = AWSTranscriptHandler(self.stream.output_stream)

    async def disconnect(self, close_code):
        await self.stream.input_stream.end_stream()

    async def receive(self, text_data=None, bytes_data=None):
        if bytes_data:
            await self.stream.input_stream.send_audio_event(audio_chunk=bytes_data)
            await self.handler.handle_events()

    async def send_transcript(self, event):
        await self.send(
            text_data=json.dumps({"type": "transcript", "message": event["message"]})
        )