rajeshl
rajeshl
/ migrate_amq_messages.py
Last active
October 29, 2016 01:59
A simple tool to migrate messages from a given AMQP Q to a different Q, with throttling. Shovel works great for bulk copy. This tool is useful when there is a need to control the speed at which migration happens.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| #!/usr/bin/env python | |
| import pika | |
| import sys | |
| import signal | |
| import time | |
| import datetime | |
| import argparse | |
| #TODO cleanup at signal handler | |
| def signal_handler(signum, frame): |