auto commit

wsps/tasks_loop.py

@@ -20,6 +20,9 @@ p=print
 async def anop(*a,**kw):pass
 def nop(*a,**kw):pass
 
+def connect_redis():
+	return redis.Redis(host='localhost', port=6379, db=0,charset="utf-8", decode_responses=True, encoding_errors="backslashreplace")
+
 
 '''
 # '''
@@ -32,7 +35,7 @@ class globCL():
 		# for now we are not going to do any weird class stuff
 		cls = self.__class__
 		cls.init_cnt += 1
-
+		self.r = connect_redis()
 		pass
 	async def persistent_loop(self,*a,**kw):
 		pass
@@ -50,3 +53,42 @@ glob_cl =  globCL()
 
 
 
+
+
+
+
+
+
+
+
+def redis_info():
+	rconn = glob_cl.r
+	keys = rconn.keys()
+	for k in keys():
+		p(":",k)
+
+	p("len(keys)",len(keys))
+	print("",end="",flush=True)
+redis_info()
+r"""
+
+def atexit_fn():
+    pass
+    # rconn.flushall()
+    print("ATEXIT FN")
+    rinfo_len()
+    keys = rconn.keys()
+    print(keys)
+    print(len(keys))
+    print("t 000")
+    # time.sleep(10)
+    print("t 010")
+    # time.sleep(20)
+    print("t 020")
+    print("ATEXIT FN...")
+    rconn.flushall()
+atexit.register(atexit_fn)
+
+
+
+# """