Save all crawled datas in database

1 files changed, 14 insertions, 1 deletions

diff --git a/crawler/neodarznet/pipelines.py b/crawler/neodarznet/pipelines.py
index 71e7865..6703796 100644
--- a/crawler/neodarznet/pipelines.py
+++ b/crawler/neodarznet/pipelines.py
@@ -1,6 +1,19 @@
 # -*- coding: utf-8 -*-
+import logging
+
+from database.models import Page
 
 
 class NeodarznetPipeline(object):
-    def process_time(self, item, spider):
+
+    def process_item(self, item, spider):
+        try:
+            page = Page.get(Page.url == item['url'])
+            q = Page.update(**item).where(Page.url == item['url'])
+            q.execute()
+            logging.info("Update item {}".format(page))
+        except Page.DoesNotExist:
+            page = Page.create(**item)
+            logging.info("Create item {}".format(page))
+        logging.info('Item {} stored in db'.format(page))
         return item