hgg070/hgg070_spider/pipelines/zuqiu.py

from twisted.internet import defer,reactor
from ..utils.helper import Helper

class ZuqiuPipeline(object):
    def open_spider(self, spider):
        pass
    @defer.inlineCallbacks
    def process_item(self,item,spider):
        out=defer.Deferred()
        reactor.callInThread(self._do_calculation,item,out)
        yield out

    def _do_calculation(self,item,out):
        param={"id":item["id"],"league":item["league"],"team_h":item["team_h"],
               "team_c":item["team_c"],"ior_RTS2Y":item["ior_RTS2Y"],"ior_RTS2N":item["ior_RTS2N"],
               "ior_REH":item["ior_REH"],"ior_REC":item["ior_REC"],"ior_ROUC":item["ior_ROUC"],
               "ior_HROUH":item["ior_HROUH"],"ratio_rouo":item["ratio_rouo"],"ratio_rouu":item["ratio_rouu"]}
        data=Helper.async_post("")