fix: 解决mq批次问题

sdk/RabbitMQ.py

@@ -36,7 +36,7 @@ class RabbitMQ(object):
                                       credentials=credentials))
         self.channel = self.connect.channel()  # 客户端连接rabbitmq服务端后开辟管道，每个channel代表一个会话任务
 
-        self.channel.basic_qos(prefetch_size=500)
+        self.channel.basic_qos(prefetch_count=500)
 
     @retry(tries=5, delay=1)
     def send_by_fanout(self, exchange, body):