tasks.py 文件源码

def get_data_from_feed(feed, posts, loop):
    try:
        data = parse(feed)
        if data.bozo == 0:
            category = data['feed']['title']
            if len(category) > 0:
                gather(*[parse_item(posts=posts, data=data, feed=feed, \
                    category=category, i=i, loop=loop) for i in range(0, \
                    len(data.entries))], return_exceptions=True)
        else:
            err = data.bozo_exception
            print(colored.red("Feed {0} is malformed: {1}".format(feed, err)))
            source_obj = Sources.objects.get(feed=feed)
            if source_obj.failures < 5:
                source_obj.failures = source_obj.failures + 1
            else:
                source_obj.failures = source_obj.failures + 1
                source_obj.active = False
            source_obj.save()
    except Exception as err:
        print(colored.red("At get_data_from_feed {}".format(err)))