Merge pull request #366 from shenxiangzhuang/python_pep8

Fix: make python code fellow pep8

python/emit_log.py

@@ -1,7 +1,8 @@
 #!/usr/bin/env python
-import pika
 import sys
 
+import pika
+
 connection = pika.BlockingConnection(
     pika.ConnectionParameters(host='localhost'))
 channel = connection.channel()

python/emit_log_direct.py

@@ -1,7 +1,8 @@
 #!/usr/bin/env python
-import pika
 import sys
 
+import pika
+
 connection = pika.BlockingConnection(
     pika.ConnectionParameters(host='localhost'))
 channel = connection.channel()

python/emit_log_topic.py

@@ -1,7 +1,8 @@
 #!/usr/bin/env python
-import pika
 import sys
 
+import pika
+
 connection = pika.BlockingConnection(
     pika.ConnectionParameters(host='localhost'))
 channel = connection.channel()

python/new_task.py

@@ -1,7 +1,8 @@
 #!/usr/bin/env python
-import pika
 import sys
 
+import pika
+
 connection = pika.BlockingConnection(
     pika.ConnectionParameters(host='localhost'))
 channel = connection.channel()

python/receive.py

@@ -1,5 +1,8 @@
 #!/usr/bin/env python
-import pika, sys, os
+import os
+import pika
+import sys
+
 
 def main():
     connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
@@ -15,6 +18,7 @@ def main():
     print(' [*] Waiting for messages. To exit press CTRL+C')
     channel.start_consuming()
 
+
 if __name__ == '__main__':
     try:
         main()

python/receive_logs.py

@@ -1,5 +1,8 @@
 #!/usr/bin/env python
-import pika, sys, os
+import os
+import pika
+import sys
+
 
 def main():
     connection = pika.BlockingConnection(

python/receive_logs_direct.py

@@ -1,9 +1,12 @@
 #!/usr/bin/env python
-import pika, sys, os
+import os
+import pika
+import sys
+
 
 def main():
     connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
+        pika.ConnectionParameters(host='localhost'))
     channel = connection.channel()
 
     channel.exchange_declare(exchange='direct_logs', exchange_type='direct')
@@ -22,11 +25,9 @@ def main():
 
     print(' [*] Waiting for logs. To exit press CTRL+C')
 
-
     def callback(ch, method, properties, body):
         print(f" [x] {method.routing_key}:{body.decode()}")
 
-
     channel.basic_consume(
         queue=queue_name, on_message_callback=callback, auto_ack=True)
 

python/receive_logs_topic.py

@@ -1,9 +1,12 @@
 #!/usr/bin/env python
-import pika, sys, os
+import os
+import pika
+import sys
+
 
 def main():
     connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
+        pika.ConnectionParameters(host='localhost'))
     channel = connection.channel()
 
     channel.exchange_declare(exchange='topic_logs', exchange_type='topic')
@@ -22,11 +25,9 @@ def main():
 
     print(' [*] Waiting for logs. To exit press CTRL+C')
 
-
     def callback(ch, method, properties, body):
         print(f" [x] {method.routing_key}:{body.decode()}")
 
-
     channel.basic_consume(
         queue=queue_name, on_message_callback=callback, auto_ack=True)
 

python/rpc_client.py

@@ -1,7 +1,8 @@
 #!/usr/bin/env python
-import pika
 import uuid
 
+import pika
+
 
 class FibonacciRpcClient(object):
 

python/rpc_server.py

@@ -26,7 +26,7 @@ def on_request(ch, method, props, body):
 
     ch.basic_publish(exchange='',
                      routing_key=props.reply_to,
-                     properties=pika.BasicProperties(correlation_id = \
+                     properties=pika.BasicProperties(correlation_id= \
                                                          props.correlation_id),
                      body=str(response))
     ch.basic_ack(delivery_tag=method.delivery_tag)

python/worker.py

@@ -1,7 +1,8 @@
 #!/usr/bin/env python
-import pika
 import time
 
+import pika
+
 connection = pika.BlockingConnection(
     pika.ConnectionParameters(host='localhost'))
 channel = connection.channel()