topic_group_queue.py 736 B

12345678910111213141516171819202122232425262728
  1. class TopicGroup(object):
  2. """
  3. 生成topic,group, platform, mode等信息
  4. """
  5. def __init__(self):
  6. self.spider_list = [
  7. # ("test", "recommend", "test"),
  8. # ("zhsdm", "recommend", "zhuhaoshiduomo"),
  9. ("fxs", "recommend", "fuxiaoshun")
  10. ]
  11. def produce(self):
  12. """
  13. 工作代码
  14. :return: list [{}, {}, {}, {}, {}]
  15. """
  16. result = [
  17. {
  18. "topic": "{}_{}_prod".format(i[0], i[1]),
  19. "group": "{}_{}_prod".format(i[0], i[1]),
  20. "mode": i[1],
  21. "platform": i[2]
  22. } for i in self.spider_list
  23. ]
  24. return result
  25. # print(TopicGroup().produce())