[bugfix]Fix transcribed text not continually.

cli.py

@@ -3,7 +3,7 @@ from consumer.asr import TranscribeConsumer
 
 def cli():
     transcribe_consumer = TranscribeConsumer()
-    transcribe_consumer.consume_messages(transcribe_consumer.queue_name, transcribe_consumer.consume)
+    transcribe_consumer.consume_messages(transcribe_consumer.input_queue_name, transcribe_consumer.consume)
 
 
 if __name__ == '__main__':

consumer/asr.py

@@ -50,8 +50,10 @@ class TranscribeConsumer(BasicMessageReceiver):
         super().__init__()
 
         self.exchange_name = 'transcribe'
-        self.queue_name = 'transcribe-input'
-        self.routing_key = 'transcribe-input'
+        self.input_queue_name = 'transcribe-input'
+        self.input_routing_key = 'transcribe-input'
+        self.output_queue_name = 'transcribe-output'
+        self.output_routing_key = 'transcribe-output'
 
         self.setup_consume_parameters()
 
@@ -62,9 +64,24 @@ class TranscribeConsumer(BasicMessageReceiver):
         logger.info('Load model finished.')
 
     def setup_consume_parameters(self):
+        logger.info(
+            f'Create consumer exchange: {self.exchange_name}, '
+            f'routing-key: {self.input_routing_key}, '
+            f'queue: {self.input_queue_name}'
+        )
+        self.declare_exchange(self.exchange_name)
+        self.declare_queue(self.input_queue_name, max_priority=-1)
+        self.bind_queue(self.exchange_name, self.input_queue_name, self.input_routing_key)
+
+    def setup_producer_parameters(self):
+        logger.info(
+            f'Create producer exchange: {self.exchange_name}, '
+            f'routing-key: {self.output_routing_key}, '
+            f'queue: {self.output_queue_name}'
+        )
         self.declare_exchange(self.exchange_name)
-        self.declare_queue(self.queue_name, max_priority=-1)
-        self.bind_queue(self.exchange_name, self.queue_name, self.routing_key)
+        self.declare_queue(self.output_queue_name, max_priority=-1)
+        self.bind_queue(self.exchange_name, self.output_queue_name, self.output_routing_key)
 
     def send_message(self, message: Union[dict, str]):
         routing_key = 'transcribe-output'
@@ -109,11 +126,11 @@ class TranscribeConsumer(BasicMessageReceiver):
             logger.info(f'Start transcribe input...')
             segments, _ = self.asr_model.transcribe(audio_file, language=validated_message.language)
 
-            transcribed_text = ''
+            transcribed_segment_text = []
             for segment in segments:
-                transcribed_text = segment.text
-                logger.info(f'Transcribed text: {transcribed_text}')
-                break
+                transcribed_segment_text.append(segment.text)
+            transcribed_text = ', '.join(transcribed_segment_text)
+            logger.info(f'Transcribed text: {transcribed_text}')
         except ValidationError as exc:
             logging.exception('Message validated failed: \n message:\n %s\n\n exception info:\n %s', message, exc)
             self.send_fail_message(body.get('uuid'), f'{exc}')