更改返回错误状态码

hg3535/pipeline/lanqiu.py

@@ -20,7 +20,7 @@ class Lanqiupipeline(object):
         out = defer.Deferred()
         reactor.callInThread(self._do_calculation, item, out)
         yield out
-        defer.returnValue(item)
+        # defer.returnValue(item)
 
     # def process_item(self, item, spider):
 

hg3535/pipeline/roll_bangqiu.py

@@ -18,7 +18,7 @@ class Roll_Banqiupipeline(object):
         out = defer.Deferred()
         reactor.callInThread(self._do_calculation, item, out)
         yield out
-        defer.returnValue(item)
+        # defer.returnValue(item)
 
     # def process_item(self, item, spider):
     def _do_calculation(self, item, out):

hg3535/pipeline/roll_lanqiu.py

@@ -19,7 +19,7 @@ class Roll_Lanqiupipeline(object):
         out = defer.Deferred()
         reactor.callInThread(self._do_calculation, item, out)
         yield out
-        defer.returnValue(item)
+        # defer.returnValue(item)
 
     # def process_item(self, item, spider):
     def _do_calculation(self, item, out):

hg3535/pipeline/roll_wangqiu.py

@@ -19,7 +19,7 @@ class Roll_Wangqiupipeline(object):
         out = defer.Deferred()
         reactor.callInThread(self._do_calculation, item, out)
         yield out
-        defer.returnValue(item)
+        # defer.returnValue(item)
     #
     def _do_calculation(self, item, out):
     # def process_item(self, item, spider):

hg3535/pipeline/roll_zuqiu.py

@@ -22,7 +22,7 @@ class Roll_Zuqiupipeline(object):
         out = defer.Deferred()
         reactor.callInThread(self._do_calculation, item, out)
         yield out
-        defer.returnValue(item)
+        # defer.returnValue(item)
 
     # def process_item(self, item, spider):
     def _do_calculation(self, item, out):

hg3535/pipeline/wangqiu.py

@@ -23,7 +23,7 @@ class Wangqiupipeline(object):
         out = defer.Deferred()
         reactor.callInThread(self._do_calculation, item, out)
         yield out
-        defer.returnValue(item)
+        # defer.returnValue(item)
 
     def _do_calculation(self, item, out):
         logger = logging.getLogger(__name__)

hg3535/pipeline/zuqiu.py

@@ -20,7 +20,7 @@ class Zuqiupipeline(object):
         out = defer.Deferred()
         reactor.callInThread(self._do_calculation, item, out)
         yield out
-        defer.returnValue(item)
+        # defer.returnValue(item)
 
     # def process_item(self, item, spider):
     def _do_calculation(self, item, out):

hg3535/utils/helper.py

@@ -1,6 +1,6 @@
 import hashlib
 import json
-import requests
+# import requests
 from requests_futures.sessions import FuturesSession