争霸测试

v2/consumer.py

@@ -17,7 +17,7 @@ def create_consumer(partition=-1):
             # print(msg)
             topic = msg.topic
             val = msg.value
-            if val.get('owner_name') not in ('gmhdgdt', 'gmhdtt'):
+            if val.get('properties',{}).get('owner_name') not in ('gmhdgdt', 'gmhdtt'):
                 continue
             yield topic, val
 

v2/event_attr.py

@@ -11,7 +11,7 @@ class EventAttr:
         attr = self.event_attr.get(key)
         if not attr:
             self.event_attr[key] = self.rdb.smembers(key) or set()
-        return self.event_attr[key]
+        return set(self.event_attr[key])
 
     def set_event_attr(self, key, *data):
         self.rdb.sadd(key, *data)