topic_group_queue.py 566 B

123456789101112131415161718192021
  1. class TopicGroup(object):
  2. def __init__(self):
  3. self.spider_list = [
  4. ("test", "recommend", "test"),
  5. ("zhsdm", "recommend", "zhuhaoshiduomo"),
  6. # ("zchqs", "recommend"),
  7. ]
  8. def produce(self):
  9. result = [
  10. {
  11. "topic": "{}_{}_prod".format(i[0], i[1]),
  12. "group": "{}_{}_prod".format(i[0], i[1]),
  13. "mode": i[1],
  14. "platform": i[2]
  15. } for i in self.spider_list
  16. ]
  17. return result
  18. # print(TopicGroup().produce())