Skip to content

Transaction Commands

Bases: BaseCommand

Mixin for Redis Transaction / pipeline commands (e.g. MULTI, EXEC, WATCH).

Source code in pyredis/commands/transaction.py 
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
class Transaction(BaseCommand):
    """Mixin for Redis Transaction / pipeline commands (e.g. MULTI, EXEC, WATCH)."""

    def __init__(self):
        super().__init__()

    def discard(self, *args, shard_key=None, sock=None):
        if self._cluster:
            return self.execute(
                *[b"DISCARD", *args],
                shard_key=shard_key,
                sock=sock
            )
        return self.execute(
            *[b"DISCARD", *args]
        )

    def exec(self, *args, shard_key=None, sock=None):
        if self._cluster:
            return self.execute(
                *[b"EXEC", *args],
                shard_key=shard_key,
                sock=sock
            )
        return self.execute(
            *[b"EXEC", *args]
        )

    def multi(self, *args, shard_key=None, sock=None):
        if self._cluster:
            return self.execute(
                *[b"MULTI", *args],
                shard_key=shard_key,
                sock=sock
            )
        return self.execute(
            *[b"MULTI", *args]
        )

    def unwatch(self, *args, shard_key=None, sock=None):
        if self._cluster:
            return self.execute(
                *[b"UNWATCH", *args],
                shard_key=shard_key,
                sock=sock
            )
        return self.execute(
            *[b"UNWATCH", *args]
        )

    def watch(self, *args):
        if self._cluster:
            return self.execute(
                *[b"WATCH", *args],
                shard_key=args[0]
            )
        return self.execute(
            *[b"WATCH", *args]
        )

__init__()

Source code in pyredis/commands/transaction.py 
7
8
def __init__(self):
    super().__init__()

discard(*args, shard_key=None, sock=None)

Source code in pyredis/commands/transaction.py 
10
11
12
13
14
15
16
17
18
19
def discard(self, *args, shard_key=None, sock=None):
    if self._cluster:
        return self.execute(
            *[b"DISCARD", *args],
            shard_key=shard_key,
            sock=sock
        )
    return self.execute(
        *[b"DISCARD", *args]
    )

exec(*args, shard_key=None, sock=None)

Source code in pyredis/commands/transaction.py 
21
22
23
24
25
26
27
28
29
30
def exec(self, *args, shard_key=None, sock=None):
    if self._cluster:
        return self.execute(
            *[b"EXEC", *args],
            shard_key=shard_key,
            sock=sock
        )
    return self.execute(
        *[b"EXEC", *args]
    )

execute(*args, **kwargs)

Source code in pyredis/commands/base.py 
5
6
def execute(self, *args, **kwargs):
    raise NotImplementedError

multi(*args, shard_key=None, sock=None)

Source code in pyredis/commands/transaction.py 
32
33
34
35
36
37
38
39
40
41
def multi(self, *args, shard_key=None, sock=None):
    if self._cluster:
        return self.execute(
            *[b"MULTI", *args],
            shard_key=shard_key,
            sock=sock
        )
    return self.execute(
        *[b"MULTI", *args]
    )

unwatch(*args, shard_key=None, sock=None)

Source code in pyredis/commands/transaction.py 
43
44
45
46
47
48
49
50
51
52
def unwatch(self, *args, shard_key=None, sock=None):
    if self._cluster:
        return self.execute(
            *[b"UNWATCH", *args],
            shard_key=shard_key,
            sock=sock
        )
    return self.execute(
        *[b"UNWATCH", *args]
    )

watch(*args)

Source code in pyredis/commands/transaction.py 
54
55
56
57
58
59
60
61
62
def watch(self, *args):
    if self._cluster:
        return self.execute(
            *[b"WATCH", *args],
            shard_key=args[0]
        )
    return self.execute(
        *[b"WATCH", *args]
    )