首页 > 编程语言 > 详细

Python:浮动等待

时间:2021-05-19 16:40:48      阅读:16      评论:0      收藏:0      [点我收藏+]

浮动等待达到某一条件

 

技术分享图片
def wait_until_expect_redis_result(redis_key, interval=1, max_waittime=30, expect_result=exist,redis_ip=127.48.167.201,redis_port=9052):
    """
    浮动等待redis队列为期待的结果
    :param redis_key: 如cache:task:expirefile:expired-redis
    :param interval:
    :param max_waittime:
    :param expect_result: exist/notexist
    :return:
    """
    print uredis_ip:,redis_ip,uredis_port:,redis_port
    wait_time = 0
    flag = ‘‘
    times = int(max_waittime/interval)
    r = redis.Redis(host=redis_ip,port=redis_port,password=WCS_REDIS_!(0))
    print uredis_key: ,redis_key
    print u"获取当前redis队列中是否存在指定队列:"
    for i in range(0, times):
        redisQueue = r.keys(redis_key)
        print i,redisQueue
        if redisQueue == []:
            flag = notexist
        else:
            flag = exist
        if flag == expect_result:
            print u\nSuccess. 当前redis队列[%s],和期望的[%s]一致,等待总时长:%s %(flag, expect_result, wait_time)
            return redisQueue
        time.sleep(interval)
        wait_time = wait_time + interval
    print u"\nError. 当前redis队列[%s],和期望的[%s]不一致,已到达允许等待最大时长:%s" % (flag, expect_result, max_waittime)
    raise AssertionError(uFail.)
View Code

 

Python:浮动等待

原文:https://www.cnblogs.com/channy14/p/14784909.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!