Redis 哈希把相关字段收拢在一个键下

redis_lab=$(mktemp -d)
curl --fail --location --output "$redis_lab/redis.tar.gz" https://download.redis.io/releases/redis-8.10.1.tar.gz
tar -xzf "$redis_lab/redis.tar.gz" -C "$redis_lab"
make -C "$redis_lab/redis-8.10.1" build redis -j2 MALLOC=libc
export REDIS_SERVER="$redis_lab/redis-8.10.1/src/redis-server"
python3 -m venv "$redis_lab/venv"
"$redis_lab/venv/bin/python" -m pip install redis==8.1.0

from contextlib import contextmanager
import os
from pathlib import Path
import subprocess
from tempfile import TemporaryDirectory
import time

import redis
from redis.backoff import NoBackoff
from redis.retry import Retry


@contextmanager
def instance():
    with TemporaryDirectory(prefix="redis-lab-", dir="/tmp") as directory:
        endpoint = str(Path(directory) / "redis.sock")
        process = subprocess.Popen([
            os.environ["REDIS_SERVER"], "--port", "0",
            "--unixsocket", endpoint, "--unixsocketperm", "700",
            "--save", "", "--appendonly", "no", "--dir", directory,
            "--maxmemory-policy", "noeviction",
        ], stdout=subprocess.DEVNULL, stderr=subprocess.PIPE)
        client = redis.Redis(unix_socket_path=endpoint, decode_responses=False,
                             socket_timeout=2, retry=Retry(NoBackoff(), 0))
        try:
            deadline = time.monotonic() + 5
            while True:
                assert process.poll() is None, "Redis exited during startup"
                try:
                    if client.ping():
                        break
                except redis.ConnectionError:
                    if time.monotonic() >= deadline:
                        raise
                    time.sleep(0.02)
            yield client
        finally:
            client.close()
            if process.poll() is None:
                process.terminate()
            try:
                _, errors = process.communicate(timeout=5)
            except subprocess.TimeoutExpired:
                process.kill()
                process.communicate()
                raise
            assert process.returncode == 0, errors.decode()



with instance() as client:
    assert client.hset("profile", mapping={
        "name": b"Ada", "score": b"0", "empty": b"",
    }) == 3
    assert client.hset("profile", "name", b"Ada L") == 0
    assert client.hmget("profile", ["name", "empty", "missing"]) == [
        b"Ada L", b"", None,
    ]
    assert client.hlen("profile") == 3
    print("HSET reports added fields, not updates; empty bytes differ from None")

    assert client.pexpire("profile", 60000)
    key_deadline = client.pexpiretime("profile")
    assert client.hpexpire("profile", 30000, "name", "score") == [1, 1]
    field_deadlines = client.hpexpiretime("profile", "name", "score")
    assert all(value > 0 for value in field_deadlines)
    assert client.hset("profile", "name", b"Grace") == 0
    assert client.pexpiretime("profile") == key_deadline
    assert client.hpttl("profile", "name") == [-1]
    assert client.hincrby("profile", "score", 1) == 1
    assert client.hpexpiretime("profile", "score") == [field_deadlines[1]]
    print("HSET keeps key TTL but clears its field TTL; HINCRBY keeps field TTL")

    assert client.hsetex("session", mapping={"token": b"A"}, px=60000) == 1
    token_deadline = client.hpexpiretime("session", "token")
    assert token_deadline[0] > 0
    assert client.hsetex("session", mapping={"token": b"B"}, keepttl=True) == 1
    assert client.hget("session", "token") == b"B"
    assert client.hpexpiretime("session", "token") == token_deadline
    print("HSETEX writes field value and TTL together; KEEPTTL preserves its deadline")

    client.hset("race", "score", 0)
    a = int(client.hget("race", "score"))
    b = int(client.hget("race", "score"))
    client.hset("race", "score", a + 1)
    client.hset("race", "score", b + 1)
    assert client.hget("race", "score") == b"1"
    client.hset("race", "score", 0)
    assert client.hincrby("race", "score", 1) == 1
    assert client.hincrby("race", "score", 1) == 2
    print("controlled stale-read schedule loses an update; two HINCRBY calls yield 2")

    client.hset("bad", "score", b"3.5")
    try:
        client.hincrby("bad", "score", 1)
    except redis.ResponseError:
        pass
    else:
        raise AssertionError("HINCRBY requires an integer")
    assert client.hget("bad", "score") == b"3.5"
    client.set("blob", b'{"name": "Ada"}')
    try:
        client.hget("blob", "name")
    except redis.ResponseError as error:
        assert "WRONGTYPE" in str(error)
    else:
        raise AssertionError("a serialized string is not a Redis hash")
    print("invalid counters and wrong key types are rejected")

    client.hset("single", "field", b"value")
    assert client.hdel("single", "missing") == 0
    assert client.hdel("single", "field") == 1
    assert client.exists("single") == 0
    print("HDEL of the last field removes the key")