def create_continuous_query(database, name, query, **client_args):
 client = _client(**client_args)
 full_query = 'CREATE CONTINUOUS QUERY {0} ON {1} BEGIN {2} END'
 query = full_query.format(name, database, query)
 client.query(query)
 return True

def create_continuous_query ( database , name , query , ** client_args ) : client = _client ( ** client_args ) full_query = 'CREATE CONTINUOUS QUERY {0} ON {1} BEGIN {2} END' query = full_query . format ( name , database , query ) client . query ( query ) return True
create a continuous query .