automatic_crawler/application/config/topic_group_queue.py

class TopicGroup(object):
    """
    生成topic，group， platform， mode等信息
    """
    def __init__(self):
        self.spider_list = [
            ("zhsdm", "recommend", "zhuhaoshiduomo"),
            ("fxs", "recommend", "fuxiaoshun"),
            ("zwwfsn", "recommend", "zhuwanwufusunew"),
            ('zjsjmn', 'recommend', 'zhujinshanjinmeinew'),
            ('hhxxzfdn', 'recommend', 'huanhuanxixizhufudaonew'),
            ('bqzf', 'recommend', 'boqingzhufu'),
            ('syzf', 'recommend', 'sharkzhufu'),
            ("xsdd", 'recommend', 'xishiduoduo'),
            ("jxxf", 'recommend', 'jixiangxingfu'),
            ("xnght", 'recommend', 'xiaoniangaohuati'),
            ('ynfqcz', 'recommend', 'yuannifuqichangzai'),
            ('zhdsn', 'recommend', 'zuihaodesongni'),
            ('jrzf', 'recommend', 'jierizhufu'),
            ('ttjfq', 'recommend', 'tiantianjufuqi')
        ]

    def produce(self):
        """
        工作代码
        :return: list [{}, {}, {}, {}, {}]
        """
        result = [
            {
                "topic": "{}_{}_prod".format(i[0], i[1]),
                "group": "{}_{}_prod".format(i[0], i[1]),
                "mode": i[1],
                "platform": i[2]
            } for i in self.spider_list
        ]
        return result


# print(TopicGroup().produce())