subscription_handler.py 文件源码

def on_subscribe(self, subid, data):
        query = data.get('query')
        op_name = self._get_op_name(query)
        app_log.info('subscrption start: subid=%s query=%s op_name=%s',
                     subid, query, op_name)
        if op_name in self.subscriptions:
            del self.subscriptions[op_name]
        self.subscriptions[op_name] = subid
        app_log.debug('subscriptions: %s', self.subscriptions)
        self.write_message(json_encode({
            'type': 'subscription_success',
            'id': subid
        }))