code: def send_task(self, body):
          
          self.ch.basic_publish(exchange='', routing_key=self.task_queue,
              properties=pika.BasicProperties(delivery_mode=2), body=body)
docs: 发送任务到任务队列
          :param body: 消息
          :return: