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)))
评论列表
文章目录