本文整理汇总了Python中redis.delete函数的典型用法代码示例。如果您正苦于以下问题:Python delete函数的具体用法?Python delete怎么用?Python delete使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了delete函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: deltestdata_api
def deltestdata_api():
print 'deleting test data'
for email2key in [redis_book_key_from_email,
redis_auth_key_from_email]:
print email2key('[email protected]')
redis.delete(email2key('[email protected]'))
return jsonify({'ip': get_remote_ip()}), 200
开发者ID:objarni,项目名称:remind-backend,代码行数:7,代码来源:server.py
示例2: resubmit_jobs
def resubmit_jobs():
if config.get('ckan.harvest.mq.type') != 'redis':
return
redis = get_connection()
log.debug('_create_or_update_package')
harvest_object_pending = redis.keys('harvest_object_id:*')
for key in harvest_object_pending:
date_of_key = datetime.datetime.strptime(redis.get(key),
"%Y-%m-%d %H:%M:%S.%f")
if (datetime.datetime.now() - date_of_key).seconds > 180: # 3 minuites for fetch and import max
redis.rpush('harvest_object_id',
json.dumps({'harvest_object_id': key.split(':')[-1]})
)
redis.delete(key)
harvest_jobs_pending = redis.keys('harvest_job_id:*')
for key in harvest_jobs_pending:
date_of_key = datetime.datetime.strptime(redis.get(key),
"%Y-%m-%d %H:%M:%S.%f")
if (datetime.datetime.now() - date_of_key).seconds > 7200: # 3 hours for a gather
redis.rpush('harvest_job_id',
json.dumps({'harvest_job_id': key.split(':')[-1]})
)
redis.delete(key)
开发者ID:simonliu0315,项目名称:ckanext-harvest,代码行数:25,代码来源:queue.py
示例3: generateSet
def generateSet(products,tmpSetName):
'''
Generate a temporary union set for the given products list.
'''
print "generateSet()"
if len(products)==0:
print "Parameter(products) is empty!"
return None
redis = brconfig.getRedis()
pipe = redis.pipeline(transaction=True)
sets=[]
for p in products:
sets.append("ids:i:android.os.Build.PRODUCT:%s"%p)
pipe.sunionstore(tmpSetName,sets)
ret=pipe.execute()
if ret[0]==0:
redis.delete(tmpSetName)
print "Generated an empty set!"
return None
else:
return tmpSetName
开发者ID:liuct,项目名称:bugquery-lt,代码行数:26,代码来源:brquery.py
示例4: resubmit_jobs
def resubmit_jobs():
'''
Examines the fetch and gather queues for items that are suspiciously old.
These are removed from the queues and placed back on them afresh, to ensure
the fetch & gather consumers are triggered to process it.
'''
if config.get('ckan.harvest.mq.type') != 'redis':
return
redis = get_connection()
# fetch queue
harvest_object_pending = redis.keys(get_fetch_routing_key() + ':*')
for key in harvest_object_pending:
date_of_key = datetime.datetime.strptime(redis.get(key),
"%Y-%m-%d %H:%M:%S.%f")
# 3 minutes for fetch and import max
if (datetime.datetime.now() - date_of_key).seconds > 180:
redis.rpush(get_fetch_routing_key(),
json.dumps({'harvest_object_id': key.split(':')[-1]})
)
redis.delete(key)
# gather queue
harvest_jobs_pending = redis.keys(get_gather_routing_key() + ':*')
for key in harvest_jobs_pending:
date_of_key = datetime.datetime.strptime(redis.get(key),
"%Y-%m-%d %H:%M:%S.%f")
# 3 hours for a gather
if (datetime.datetime.now() - date_of_key).seconds > 7200:
redis.rpush(get_gather_routing_key(),
json.dumps({'harvest_job_id': key.split(':')[-1]})
)
redis.delete(key)
开发者ID:geosolutions-it,项目名称:ckanext-harvest,代码行数:33,代码来源:queue.py
示例5: diagnose_cb
def diagnose_cb():
user_session = get_session(redis,request.values.get('CallSid'))
symptom = urllib.unquote(request.args.get('symptom'))
print symptom
resp = twilio.twiml.Response()
digit_pressed = request.values.get('Digits', None)
if digit_pressed == "1":
user_session['symptom_whitelist'].append(symptom)
set_session(redis,request.values.get('CallSid'), user_session)
else:
user_session['symptom_blacklist'].append(symptom)
set_session(redis,request.values.get('CallSid'), user_session)
diseases = symptomelimination.calculate_probability_for_disease(user_session['location'], user_session['symptom_whitelist'])
# its for the case that no user input is made (so people will not have a disease without symptom)
if len(user_session['symptom_whitelist']) == 0:
for disease in diseases:
disease['probability'] = 0
diseases = sorted(diseases, cmp=lambda x, y: cmp(y['probability'],x['probability']))
for disease in diseases:
print helpers.get_name_for_disease(disease['disease']), disease['probability']
if user_session['question_count'] >= 3 and diseases[0]['probability'] > 0.8:
resp.say("We have determined there is a high probability you have {0}".format(helpers.get_name_for_disease(diseases[0]['disease'])),**default_ops)
resp.say("We suggest you seek medical attention as soon as possible",**default_ops)
resp.hangup()
redis.delete(request.values.get('CallSid'))
elif user_session['question_count'] >= 7:
resp.say("Sorry, we are unable to determine what you are sick with.",**default_ops)
resp.redirect('/ems')
else:
resp.redirect('/diagnose')
return str(resp)
开发者ID:nandopeters,项目名称:teledoc,代码行数:31,代码来源:teledoc.py
示例6: DELETE
def DELETE(self, name):
#params = web.input()
#print params
clipName = name
redis.delete("cue:" + clipName)
redis.save()
cull_playlists(name)
开发者ID:paulparadiso,项目名称:delta-control,代码行数:7,代码来源:delta.py
示例7: get_accessible_ids
def get_accessible_ids(token,ids=None):
tmpSetName='tmp_%s'%str(uuid.uuid4())
tmpSetName=getAccessibleSet(token,tmpSetName,ids=ids)
if tmpSetName==None:
return None
else:
redis=brconfig.getRedis()
ret_ids=redis.smembers(tmpSetName)
redis.delete(tmpSetName)
return ret_ids
开发者ID:liuct,项目名称:bugquery-lt,代码行数:10,代码来源:brquery.py
示例8: rget
def rget(redis,key):
str = redis.get(key)
if str:
try:
object = Pickle.loads(str)
return object
except:
print "fail removing" + key
redis.delete(key)
return False
开发者ID:camathieu,项目名称:soundcloudsync,代码行数:10,代码来源:Sysaccess.py
示例9: ems
def ems():
print "Showing number to user"
user_session = get_session(redis,request.values.get('CallSid'))
number = helpers.get_phone_for_country(user_session['location'])
print number
resp = twilio.twiml.Response()
resp.say("To get emergency medical attention in your country hang up and dial {0}".format(" ".join(list(str(number)))),**default_ops)
resp.hangup()
redis.delete(request.values.get('CallSid'))
return str(resp)
开发者ID:nandopeters,项目名称:teledoc,代码行数:10,代码来源:teledoc.py
示例10: remove
def remove(sid, realm):
redis = get_redis()
redis.delete("session-%s" % sid)
try:
s = Session.select().join(User).where(
(Session.id == sid) & (User.realm == realm)).get()
s.delete_instance()
return True
except Session.DoesNotExist:
return False
开发者ID:b1naryth1ef,项目名称:hora,代码行数:10,代码来源:database.py
示例11: _clear
def _clear(self, pipe=None):
"""Helper for clear operations.
:param pipe: Redis pipe in case update is performed as a part
of transaction.
:type pipe: :class:`redis.client.StrictPipeline` or
:class:`redis.client.StrictRedis`
"""
redis = pipe if pipe is not None else self.redis
redis.delete(self.key)
开发者ID:tricoder42,项目名称:redis-collections,代码行数:10,代码来源:base.py
示例12: flush_dead_mappers
def flush_dead_mappers(redis, mappers_key, ping_key):
mappers = redis.smembers(mappers_key)
for mapper in mappers:
last_ping = redis.get(ping_key % mapper)
if last_ping:
now = datetime.now()
last_ping = datetime.strptime(last_ping, DATETIME_FORMAT)
if ((now - last_ping).seconds > TIMEOUT):
logging.warning('MAPPER %s found to be inactive after %d seconds of not pinging back' % (mapper, TIMEOUT))
redis.srem(mappers_key, mapper)
redis.delete(ping_key % mapper)
开发者ID:Mondego,项目名称:pyreco,代码行数:11,代码来源:allPythonContent.py
示例13: route_post_initialize
def route_post_initialize():
redis = get_redis()
for key in redis.keys('isu4:*'):
redis.delete(key)
shutil.rmtree(get_dir('log'))
response = make_response('OK')
response.headers['Content-Type'] = 'text/plain'
return response
开发者ID:catatsuy,项目名称:isucon4,代码行数:11,代码来源:app.py
示例14: clean
def clean():
for item in checklist:
queued = item + ":requests"
queued_num = redis.zcard(queued)
if queued_num > 0:
redis.delete(queued)
cached = item + ":items"
cached_num = redis.llen(cached)
if cached_num > 0:
redis.delete(cached)
print("Clean all queued requests successfully!")
开发者ID:wxpjimmy,项目名称:Crawler_Demo,代码行数:11,代码来源:statuscheck.py
示例15: hangup
def hangup():
try:
From = request.args['From']
CallUUID = request.args['CallUUID']
if CallUUID == redis.get(From):
redis.delete(From)
except KeyError:
pass
return "Done"
开发者ID:nikunjagr,项目名称:plivo-apps,代码行数:12,代码来源:app.py
示例16: remove_building
def remove_building(building_identifier):
status = False
try:
bldg = Building.query.filter_by(building_identifier = building_identifier).all()[0]
db.session.delete(bldg)
db.session.commit()
if config.buildings_cache_enabled == True:
redis.delete(building_identifier)
redis.delete('buildings')
status = True
except Exception as ex:
db.session.rollback()
log.debug('remove_building(): error: ' + str(ex))
return(status)
开发者ID:fterdalpdx,项目名称:finti,代码行数:14,代码来源:null_model.py
示例17: clear_sub_nodes
def clear_sub_nodes(type_name, hashcode):
namehash = "%s:%s" % (type_name, hashcode)
metahash = "%s:linked_fields:%s" % (type_name, hashcode)
m_type = redis.type(metahash)
if m_type == "list":
for index in redis.lrange(metahash, 0, -1):
i = int(index)
clear_sub_nodes(type_name, redis.lindex(namehash, i))
elif m_type == "hash":
meta_dictionary = redis.hgetall(namehash)
for key in meta_dictionary:
linked_node_hash = meta_dictionary[key]
clear_sub_nodes(type_name, linked_node_hash)
redis.delete(namehash)
redis.delete(metahash)
开发者ID:michaelgiba,项目名称:redobs,代码行数:15,代码来源:serializor.py
示例18: _xray_clean_up_entries_for_driver
def _xray_clean_up_entries_for_driver(self, driver_id):
"""Remove this driver's object/task entries from redis.
Removes control-state entries of all tasks and task return
objects belonging to the driver.
Args:
driver_id: The driver id.
"""
xray_task_table_prefix = (
ray.gcs_utils.TablePrefix_RAYLET_TASK_string.encode("ascii"))
xray_object_table_prefix = (
ray.gcs_utils.TablePrefix_OBJECT_string.encode("ascii"))
task_table_objects = self.state.task_table()
driver_id_hex = binary_to_hex(driver_id)
driver_task_id_bins = set()
for task_id_hex, task_info in task_table_objects.items():
task_table_object = task_info["TaskSpec"]
task_driver_id_hex = task_table_object["DriverID"]
if driver_id_hex != task_driver_id_hex:
# Ignore tasks that aren't from this driver.
continue
driver_task_id_bins.add(hex_to_binary(task_id_hex))
# Get objects associated with the driver.
object_table_objects = self.state.object_table()
driver_object_id_bins = set()
for object_id, _ in object_table_objects.items():
task_id_bin = ray.raylet.compute_task_id(object_id).id()
if task_id_bin in driver_task_id_bins:
driver_object_id_bins.add(object_id.id())
def to_shard_index(id_bin):
return binary_to_object_id(id_bin).redis_shard_hash() % len(
self.state.redis_clients)
# Form the redis keys to delete.
sharded_keys = [[] for _ in range(len(self.state.redis_clients))]
for task_id_bin in driver_task_id_bins:
sharded_keys[to_shard_index(task_id_bin)].append(
xray_task_table_prefix + task_id_bin)
for object_id_bin in driver_object_id_bins:
sharded_keys[to_shard_index(object_id_bin)].append(
xray_object_table_prefix + object_id_bin)
# Remove with best effort.
for shard_index in range(len(sharded_keys)):
keys = sharded_keys[shard_index]
if len(keys) == 0:
continue
redis = self.state.redis_clients[shard_index]
num_deleted = redis.delete(*keys)
logger.info("Removed {} dead redis entries of the driver from"
" redis shard {}.".format(num_deleted, shard_index))
if num_deleted != len(keys):
logger.warning("Failed to remove {} relevant redis entries"
" from redis shard {}.".format(
len(keys) - num_deleted, shard_index))
开发者ID:jamescasbon,项目名称:ray,代码行数:60,代码来源:monitor.py
示例19: send_ui_reply
def send_ui_reply():
sms_id = request.form.get('sms_id')
sms_reply = request.form.get('action')
print "Here I am: SMS Id - %s" % sms_id
if ((sms_reply != "") and (not sms_id.startswith("del"))):
src = redis.hget(sms_id,'From')
plivo_did = redis.hget(sms_id,'Plivo DID')
redis.hset(sms_id,"Replied",'y')
redis.save()
send_auto_response(src, plivo_did, sms_reply, 'True')
elif ((sms_reply != "") and (sms_reply == "del")):
redis.delete(sms_id[4:])
redis.save()
return "OK"
开发者ID:keshavagrawal89,项目名称:plivo-mailgun-redis-sms-voice,代码行数:16,代码来源:handle.py
示例20: _clean_up_entries_from_shard
def _clean_up_entries_from_shard(self, object_ids, task_ids, shard_index):
redis = self.state.redis_clients[shard_index]
# Clean up (in the future, save) entries for non-empty objects.
object_ids_locs = set()
object_ids_infos = set()
for object_id in object_ids:
# OL.
obj_loc = redis.zrange(OBJECT_LOCATION_PREFIX + object_id, 0, -1)
if obj_loc:
object_ids_locs.add(object_id)
# OI.
obj_info = redis.hgetall(OBJECT_INFO_PREFIX + object_id)
if obj_info:
object_ids_infos.add(object_id)
# Form the redis keys to delete.
keys = [TASK_TABLE_PREFIX + k for k in task_ids]
keys.extend([OBJECT_LOCATION_PREFIX + k for k in object_ids_locs])
keys.extend([OBJECT_INFO_PREFIX + k for k in object_ids_infos])
if not keys:
return
# Remove with best effort.
num_deleted = redis.delete(*keys)
log.info(
"Removed {} dead redis entries of the driver from redis shard {}.".
format(num_deleted, shard_index))
if num_deleted != len(keys):
log.warning(
"Failed to remove {} relevant redis entries"
" from redis shard {}.".format(len(keys) - num_deleted))
开发者ID:adgirish,项目名称:ray,代码行数:31,代码来源:monitor.py
注:本文中的redis.delete函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论