import pika
credentials = pika.PlainCredentials('username', 'password')
parameters = pika.ConnectionParameters('servername', credentials=credentials)
connection = pika.BlockingConnection(parameters)
for-readline = /etc/enviroment
env = %(_)
endfor =