(self, ev, sql_queue_func, qfunc_arg)
Ignore events for this table
Ignore events for this table
Ignore events for this table
def process_event(self, ev, sql_queue_func, qfunc_arg):
        """Ignore events for this table"""
        fn = self.args.get('func_name')
        fnconf = self.args.get('func_conf', '')

        args = [fnconf, self.cur_tick,
                ev.ev_id, ev.ev_time,
                ev.ev_txid, ev.ev_retry,
                ev.ev_type, ev.ev_data,
                ev.ev_extra1, ev.ev_extra2,
                ev.ev_extra3, ev.ev_extra4]

        qfn = skytools.quote_fqident(fn)
        qargs = [skytools.quote_literal(a) for a in args]
        sql = "select %s(%s);" % (qfn, ', '.join(qargs))
        self.log.debug('applyfn.sql: %s', sql)
        sql_queue_func(sql, qfunc_arg)
def process_event ( self , ev , sql_queue_func , qfunc_arg ) : fn = self . args . get ( 'func_name' ) fnconf = self . args . get ( 'func_conf' , '' ) args = [ fnconf , self . cur_tick , ev . ev_id , ev . ev_time , ev . ev_txid , ev . ev_retry , ev . ev_type , ev . ev_data , ev . ev_extra1 , ev . ev_extra2 , ev . ev_extra3 , ev . ev_extra4 ] qfn = skytools . quote_fqident ( fn ) qargs = [ skytools . quote_literal ( a ) for a in args ] sql = "select %s(%s);" % ( qfn , ', ' . join ( qargs ) ) self . log . debug ( 'applyfn.sql: %s' , sql ) sql_queue_func ( sql , qfunc_arg )