topic_group_queue.py 970 B

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