topic_group_queue.py 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253
  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. ("xsdd", 'recommend', 'xishiduoduo'),
  15. ("jxxf", 'recommend', 'jixiangxingfu'),
  16. ("xnght", 'recommend', 'xiaoniangaohuati'),
  17. ('ynfqcz', 'recommend', 'yuannifuqichangzai'),
  18. ('zhdsn', 'recommend', 'zuihaodesongni'),
  19. ('jrzf', 'recommend', 'jierizhufu'),
  20. ('dkyhy', 'recommend', 'dakaiyinghaoyun'),
  21. ('xngtjl', 'recommend', 'xiaoniangaotuijianliu'),
  22. ('zfqztjl', 'recommend', 'zhufuquanzituijianliu'),
  23. ('bszf', 'recommend', 'benshanzhufu'),
  24. ('zfnnsxjx', 'recommend', 'zhufuniannianshunxinjixiang'),
  25. ('ttjfq', 'recommend', 'tiantianjufuqi'),
  26. ('zfkz', 'recommend', 'zhufukuaizhuan'),
  27. ('lpld', 'recommend', 'lepaoledong'),
  28. ('lplddj', 'recommend', 'lepaoledongdijie'),
  29. ('pqgs', 'recommend', 'piaoquangushi'),
  30. ('wqsp', 'recommend', 'weiquanshipin'),
  31. ('llklzf', 'recommend', 'linglingkuailezhufu'),
  32. ('jrzfhkfg', 'recommend', 'jierizhufuhuakaifugui'),
  33. ('ynfqmm', 'recommend', 'yuannifuqimanman'),
  34. ('hyzfd', 'recommend', 'haoyunzhufuduo'),
  35. ]
  36. def produce(self):
  37. """
  38. 工作代码
  39. :return: list [{}, {}, {}, {}, {}]
  40. """
  41. result = [
  42. {
  43. "topic": "{}_{}_prod".format(i[0], i[1]),
  44. "group": "{}_{}_prod".format(i[0], i[1]),
  45. "mode": i[1],
  46. "platform": i[2]
  47. } for i in self.spider_list
  48. ]
  49. return result
  50. # print(TopicGroup().produce())