MyRabbit is an asynchronous publisher app based on pika that dumps selected tables from a MySQL database and publish the output on a RabbitMQ.
There are a few different ways you can install myrabbit:
- Use setuptools:
easy_install -U myrabbit_py - Checkout the source:
git clone https://github.com/bsab/MyRabbit2.gitand install it yourself.
Prepare your custom config file 'config.ini':
[rabbitmq]
rabbit_url = amqp://abcdef:[email protected]/xsdxsd?connection_attempts=3&heartbeat_interval=3600
[mysql]
mysql_url= 127.0.0.1
mysql_username= root
mysql_psw= admin
mysql_dbname= mydb
mysql_table_list=[ "tab1", "tab2", "tab3" ]Then include this snippet of code at the beginning of your python scripts:
import json
from ConfigParser import SafeConfigParser
from myrabbit_py import MyRabbitPublisher
def main():
# reading configuration file
parser = SafeConfigParser()
parser.read('config.ini')
# rabbit connection parameters
rabbit_url = str(parser.get('rabbitmq', 'rabbit_url'))
# mysql connection parameters
mysql_url = str(parser.get('mysql', 'mysql_url'))
mysql_username = str(parser.get('mysql', 'mysql_username'))
mysql_psw = str(parser.get('mysql', 'mysql_psw'))
mysql_dbname = str(parser.get('mysql', 'mysql_dbname'))
mysql_table_list = json.loads(str(parser.get('mysql', 'mysql_table_list')))
myrabbitpublisher = MyRabbitPublisher(rabbit_url,
mysql_url,
mysql_username,
mysql_psw,
mysql_dbname,
mysql_table_list)
try:
myrabbitpublisher.run()
except KeyboardInterrupt:
myrabbitpublisher.stop()
if __name__ == '__main__':
main()Contributions welcome; Please submit all pull requests against the master branch. If your pull request contains Python patches or features, you should include relevant unit tests. Thanks!
Sabatino Severino, @bsab
MyRabbit is available under the MIT license. See the LICENSE file for more info.