本文整理汇总了Python中redisco.get_client函数的典型用法代码示例。如果您正苦于以下问题:Python get_client函数的具体用法?Python get_client怎么用?Python get_client使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了get_client函数的17个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: setup_database
def setup_database(config, logger):
if config["embedded"]:
connection_setup()
db = get_client()
db.flushall()
return db
dbhost = config["dbhost"]
dbport = config["dbport"]
logger.debug(
"Waiting for Redis Service on {0:s}:{1:d} ...".format(dbhost, dbport)
)
waitfor(dbhost, dbport)
logger.debug(
"Connecting to Redis on {0:s}:{1:d} ...".format(dbhost, dbport)
)
connection_setup(host=dbhost, port=dbport)
logger.debug("Success!")
db = get_client()
db.flushall()
return db
开发者ID:carriercomm,项目名称:charla,代码行数:29,代码来源:main.py
示例2: __init__
def __init__(self):
self.channel = 'GLOBALSIGNALS'
self.workers = defaultdict(set)
self.rc = redisco.get_client()
self.ps = self.rc.pubsub()
self.ps.subscribe(self.channel)
self.funcnames = set()
gevent.spawn(self._listener)
开发者ID:pakoo,项目名称:new_deletepost,代码行数:9,代码来源:globalsignals.py
示例3: __init__
def __init__(self, model_class):
self.model_class = model_class
self.key = model_class._key['all']
self._db = redisco.get_client()
self._filters = {}
self._exclusions = {}
self._zfilters = []
self._ordering = []
self._limit = None
self._offset = None
开发者ID:89sos98,项目名称:redisco,代码行数:10,代码来源:modelset.py
示例4: setUp
def setUp(self):
"""Before each test, set up a blank database"""
gplab.app.config["TESTING"] = True
gplab.app.config["CSRF_ENABLED"] = False
connection_setup(host="localhost", port=6379, db=4)
client = get_client()
client.flushdb()
self.app = gplab.app.test_client()
开发者ID:ulule,项目名称:gplab,代码行数:11,代码来源:tests.py
示例5: __init__
def __init__(self, model_class):
self.model_class = model_class
self.key = model_class._key['all']
# We access directly _meta as .db is a property and should be
# access from an instance, not a Class
self._db = model_class._meta['db'] or redisco.get_client()
self._filters = {}
self._exclusions = {}
self._zfilters = []
self._ordering = []
self._limit = None
self._offset = None
开发者ID:Lipvun,项目名称:redisco,代码行数:12,代码来源:modelset.py
示例6: setup_database
def setup_database():
dbhost = environ.get("REDIS_PORT_6379_TCP_ADDR", "localhost")
dbport = int(environ.get("REDIS_PORT_6379_TCP_PORT", "6379"))
print("Waiting for Redis Service on {0:s}:{1:d} ...".format(dbhost, dbport))
waitfor(dbhost, dbport)
print("Connecting to Redis on {0:s}:{1:d} ...".format(dbhost, dbport))
connection_setup(host=dbhost, port=dbport)
print("Success!")
db = get_client()
return db
开发者ID:prologic,项目名称:todoapp,代码行数:17,代码来源:main.py
示例7: setup_database
def setup_database(args, logger):
dbhost = args.dbhost
dbport = args.dbport
logger.debug(
"Waiting for Redis Service on {0:s}:{1:d} ...".format(dbhost, dbport)
)
waitfor(dbhost, dbport)
logger.debug(
"Connecting to Redis on {0:s}:{1:d} ...".format(dbhost, dbport)
)
connection_setup(host=dbhost, port=dbport)
logger.debug("Success!")
db = get_client()
return db
开发者ID:carriercomm,项目名称:udns,代码行数:21,代码来源:server.py
示例8: setUp
def setUp(self):
self.client = redisco.get_client()
self.client.flushdb()
开发者ID:DeadWisdom,项目名称:redisco,代码行数:3,代码来源:models.py
示例9: exists
def exists(cls, id):
"""Checks if the model with id exists."""
_conn = cls._meta['db'] or redisco.get_client()
return bool(_conn.exists(cls.instance_key(id)) or
_conn.sismember(cls._all_key, str(id)))
开发者ID:heckj,项目名称:redisco,代码行数:5,代码来源:base.py
示例10: db
def db(self):
"""Returns the Redis client used by the model."""
if self._meta['db']:
return self._meta['db']
return redisco.get_client()
开发者ID:heckj,项目名称:redisco,代码行数:5,代码来源:base.py
示例11: display_results
def display_results(results, name):
print("%s: 5000 Loops, best of 3: %.02f sec" % (name, min(results)))
def profile():
import cProfile
import pstats
stmt = """
for x in xrange(0, 5000):
find_events()
"""
cProfile.run(stmt, "b33f.prof")
p = pstats.Stats("b33f.prof")
p.strip_dirs().sort_stats('cumulative').print_stats(20)
db = get_client()
db.flushdb()
Event(name="Redis Meetup 1", location="London").save()
t = timeit.Timer('create_events()', 'from __main__ import create_events')
display_results(t.repeat(repeat=1, number=5000), 'create_events')
t = timeit.Timer('find_events()', 'from __main__ import find_events')
display_results(t.repeat(repeat=1, number=5000), 'find_events')
t = timeit.Timer('load_events()', 'from __main__ import load_events')
display_results(t.repeat(repeat=1, number=5000), 'load_events')
开发者ID:Grokzen,项目名称:redisco,代码行数:28,代码来源:create.py
示例12: exists
def exists(cls, id):
"""Checks if the model with id exists."""
return bool((cls._meta['db'] or redisco.get_client()).exists(cls._key[str(id)]) or
(cls._meta['db'] or redisco.get_client()).sismember(cls._key['all'], str(id)))
开发者ID:baijinping,项目名称:redisco,代码行数:4,代码来源:base.py
示例13: db
def db(self):
"""Returns the Redis client used by the model."""
return redisco.get_client() if not self._meta['db'] else self._meta['db']
开发者ID:baijinping,项目名称:redisco,代码行数:3,代码来源:base.py
示例14: db
def db(self):
"""Returns the Redis client used by the model."""
return redisco.get_client()
开发者ID:nettedfish,项目名称:redisco,代码行数:3,代码来源:base.py
示例15: db
def db(cls):
"""Returns the Redis client used by the model."""
return cls.get_conn() or redisco.get_client()
开发者ID:crodjer,项目名称:mirosubs,代码行数:3,代码来源:base.py
示例16: MarketDataApi
# coding: utf8
import logging
from abc import ABCMeta, abstractmethod
import redisco
logger = logging.getLogger(__name__)
rdb = redisco.get_client()
class MarketDataApi(object):
__metaclass__ = ABCMeta
def __init__(self, quote_service, instruments, interval):
self.quote_service = quote_service
self.instruments = set(instruments)
self.quote_service.interval = interval
self.quote_service.mdapis.append(self)
def start(self):
self.subscribe(self.instruments)
def process_tick(self, tick):
# logger.debug(str(tick))
secid = tick.securityID
rdb.hset('current_price', secid, tick.price)
if hasattr(tick, 'b_price'):
rdb.hset('current_b_price', secid, tick.b_price)
if hasattr(tick, 's_price'):
rdb.hset('current_s_price', secid, tick.s_price)
rdb.publish('checkstop', secid)
开发者ID:saltduck,项目名称:sectradelib,代码行数:31,代码来源:marketdata.py
示例17: before_request
def before_request():
g.redisco_client = redisco.get_client()
#flask.g.app = app
g.logger = app.logger
开发者ID:csdurfee,项目名称:more_time,代码行数:4,代码来源:more_time.py
注:本文中的redisco.get_client函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论