加入redis连接时设置连接名称

models/database.py

@@ -7,6 +7,7 @@ import mysql.connector.pooling
 import redis
 from mysql.connector import errorcode
 import time
+import jimit as ji
 
 from initialize import app, logger
 
@@ -85,3 +86,5 @@ class Database(object):
                                       db=app.config.get('redis_dbid', 0), password=app.config.get('redis_password', ''),
                                       decode_responses=True)
 
+        cls.r.client_setname(ji.Common.get_hostname())
+

models/event_processor.py

@@ -257,6 +257,7 @@ class EventProcessor(object):
             if Utils.exit_flag:
                 Utils.thread_counter -= 1
                 print 'Thread EventProcessor say bye-bye'
+                print 'Current thread_counter: ' + Utils.thread_counter.__str__()
                 return
 
             try:

models/initialize.py

@@ -102,6 +102,7 @@ class Init(object):
             if Utils.exit_flag:
                 Utils.thread_counter -= 1
                 print 'Thread pub_sub_ping_pong say bye-bye'
+                print 'Current thread_counter: ' + Utils.thread_counter.__str__()
                 return
 
             time.sleep(10)