queue_name = result.method.queue

channel.queue_bind(exchange='bucketevents',
                   queue=queue_name)

print(' [*] Waiting for logs. To exit press CTRL+C')

def callback(ch, method, properties, body):
    print(" [x] %r" % body)

channel.basic_consume(callback,
                      queue=queue_name,
                      no_ack=False)

channel.start_consuming()
```

AOzL,SAAS,SAClClB,KAAKC,SAAS8H,QAAQ,kBAAkBX,QAAQE,KAAK,SAAS9G,YAAY,QAAQG,OAGpFX,KAAKC,SAAS8H,QAAQ,6BAA6B3E,GAAG,sBAAsB,SAASwJ,GACnF5N,EAAE,2BAA2BwB,YAAY,QAAQG,WA7ChC8L,EAoDd5J,iBAAP,SAAwB9C,GACtB,OAAOC,KAAK+C,MAAK,WACf,IAAIC,EAAYhE,EAAEgB,MAAMgD,KA/CH,gBAgDf9C,EAAUlB,EAAEkE,OAAO,GAAIxD,EAASV,EAAEgB,MAAMgD,QAEzCA,IACHA,EAAO,IAAIyJ,EAASzN,EAAEgB,MAAOE,GAC7BlB,EAAEgB,MAAMgD,KApDW,eAoDIA,IAGV,kBAAXjD,GACFiD,EAAKjD,SA/DU0M,EAAA,GAqGvB,OA3BAzN,EAAEQ,EAAyB,IAAMA,GAA0B4D,GAAG,SAAS,SAASC,GAC9EA,EAAMC,iBA...