json_rpc.py 文件源码

def _request(self, method, **params):
        """
        Send a request over whatever transport is provided
        """
        this_id = self.next_id
        self.next_id += 1
        request = r'{{"jsonrpc": "2.0", "id": {}, "method": "{}", "params": {}}}' \
                    .format(this_id, method, json.dumps(params))
        print('### SENDING REQUEST {}'.format(request))
        self.sdata.add_to_push_queue('request', text=request)
        self.sdata.transport_tx_cb(request)
        d = defer.Deferred()
        self.pending_reply_map[this_id] = d
        return d