Running multiprocessing/Multi threading in pika consumer and directing the data to specific datafram

I am new to Python multi-threading/processing and RabbitMQ. Basically i have a RabbitMQ consumer which feeds me real time hospital data . Each message comprises patients's vitals per patient. I need to store at least five such messages per patient in order to run my logic and use to set off an alarm. Also since number of the patients are unknown,i am thinking of Multi threading or Multiprocessing in order to keep my alarm almost real-time and scale up. My approach is to create a global dataframe for each patient and then append the messages pertaining that patient into the dataframe .But now I am having problem creating the Multi thread/process and sending the data to respective patient dataframe . Here is my code

bed_list=[]
thread_list=[]
bed_df={}
alarms=0

def spo2(body,bed):
    body_data= body.decode()
    print(body_data)
    packet= json.loads(body_data)
    bed_id= packet['beds'][0]['bedId']
    if bed_id=bed:
        primary_attributes= json_normalize(packet)
         '''some logic'''
        global bed_df
        bed_df[bed_id]= bed_df[bed_id].append(packet) # creating the global dataframe to store five messages
        print(bed_df[bed_id])

        ''' some other calcuation'''

            phy_channel.basic_publish(body=json.dumps(truejson),exchange='nicu')# throwing out the alarm with another queue
            bed_df[bed_id]= bed_df[bed_id].tail(4)  # resets the size of the dataframe 


def callback(ch, method, properties, body):
    body_data= body.decode()
    packet= json.loads(body_data)
    bed_id= packet['beds'][0]['bedId']
    print(bed_id)
    global bed_list
    if bed_id not in bed_list:
      bed_list.append(bed_id)


#pseudo code
 for bed in bed_list:
     proc = Process(target=spo2, args=(bed,))
     procs.append(proc)
     proc.start()

I am not able to figure a way out where i can create a thread/process for each patient(bed_id) so that whenever i receive the message for that patient(bed_id) i can direct it to that thread. I have checked Queues but the documentation is not very clear as to implement this case.