feat: [recorder] rabbitmq支持多消费

README.md

@@ -27,6 +27,7 @@ DYNACONF_RABBITMQ__HOST: 'localhost'
 DYNACONF_RABBITMQ__PORT: 5672
 DYNACONF_RABBITMQ__USER: 'guest'
 DYNACONF_RABBITMQ__PASSWORD: 'guest'
+DYNACONF_RABBITMQ__PREFETCH_COUNT: 40  # record进程数
 
 # Redis配置
 DYNACONF_REDIS__host: '127.0.0.1'

isc_video_record/recorder.py

@@ -5,6 +5,7 @@ import time
 import threading
 import functools
 import pytz
+import dynaconf
 
 from datetime import timedelta, datetime
 from intelab_python_sdk.logger import log_init, log
@@ -86,7 +87,7 @@ class StreamRecorder:
         on_message_callback = functools.partial(
             on_message, args=(self.connection, threads))
 
-        self.channel.basic_qos(prefetch_count=2)
+        self.channel.basic_qos(prefetch_count=dynaconf.settings.get('PREFETCH_COUNT', 10))
         self.channel.basic_consume(on_message_callback=on_message_callback,
                                    queue=self.queue_name)
 

setup.py

@@ -21,7 +21,7 @@ requires = [
 
 setuptools.setup(
     name='isc-video-record',
-    version='1.0.0a5',
+    version='1.0.0a6',
     description='ISC motion detection playback video stream recording service.',
     long_description=long_description,
     long_description_content_type='text/markdown',