In [ ]:

    

import datetime
import hashlib
import rabbitpy


    

In [ ]:

    

with rabbitpy.Connection() as connection:                              #A
    with connection.channel() as channel:                              #B
        for iteration in range(100000):                                #C
            timestamp = datetime.datetime.now().isoformat()            #D
            hash_value = hashlib.md5('%s:%s' % (timestamp, iteration)) #E
            msg = rabbitpy.Message(channel, 'Image # %i' % iteration,  #F
                                   {'headers': 
                                     {'image-hash': str(hash_value.hexdigest())}},
                                    opinionated=True)
            msg.publish('image-storage')                               #G