topic_group_queue.py 439 B

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