self.send_message

####self.send_message（project，msg，[url]） 將消息發(fā)送到其他項目。可以通過def on_message(self, project, message)回調(diào)接收。

• project - 其他項目名稱
• msg - 任何json-able對象
• url- 如果相同，結(jié)果將被覆蓋taskid。默認情況下send_message共享相同taskid。更改此選項可通過一個響應(yīng)返回多個結(jié)果。

    def detail_page(self, response):
        for i, each in enumerate(response.json['products']):
            self.send_message(self.project_name, {
                    "name": each['name'],
                    'price': each['prices'],
                 }, url="%s#%s" % (response.url, i))
    
    def on_message(self, project, msg):
        return msg

pyspider send_message [OPTIONS] PROJECT MESSAGE

您也可以從命令行發(fā)送消息。

    Usage: pyspider send_message [OPTIONS] PROJECT MESSAGE
    
      Send Message to project from command line
    
    Options:
      --scheduler-rpc TEXT  xmlrpc path of scheduler
      --help                Show this message and exit.

def on_message（自我，項目，消息）

從其他項目接收消息