aboutsummaryrefslogtreecommitdiff
path: root/crawler/neodarznet/pipelines.py
diff options
context:
space:
mode:
Diffstat (limited to 'crawler/neodarznet/pipelines.py')
-rw-r--r--crawler/neodarznet/pipelines.py10
1 files changed, 5 insertions, 5 deletions
diff --git a/crawler/neodarznet/pipelines.py b/crawler/neodarznet/pipelines.py
index 6703796..fbfebbb 100644
--- a/crawler/neodarznet/pipelines.py
+++ b/crawler/neodarznet/pipelines.py
@@ -1,19 +1,19 @@
# -*- coding: utf-8 -*-
import logging
-from database.models import Page
+from database.models import Neodarznet
class NeodarznetPipeline(object):
def process_item(self, item, spider):
try:
- page = Page.get(Page.url == item['url'])
- q = Page.update(**item).where(Page.url == item['url'])
+ page = Neodarznet.get(Neodarznet.url == item['url'])
+ q = Neodarznet.update(**item).where(Neodarznet.url == item['url'])
q.execute()
logging.info("Update item {}".format(page))
- except Page.DoesNotExist:
- page = Page.create(**item)
+ except Neodarznet.DoesNotExist:
+ page = Neodarznet.create(**item)
logging.info("Create item {}".format(page))
logging.info('Item {} stored in db'.format(page))
return item