task.py 文件源码

def enqueue_stream(sd_hash, num_blobs_in_stream, db_dir, client_factory_class, redis_address=settings['redis server'],
                   host_infos=None):

    timeout = (num_blobs_in_stream+1)*30
    redis_connection = get_redis_connection(redis_address)
    q = Queue(connection=redis_connection)
    q.enqueue(process_stream, sd_hash, db_dir, client_factory_class, redis_address, host_infos, timeout=timeout)