summaryrefslogtreecommitdiffstats
path: root/iredis/data/commands/xadd.md
blob: 8a805561f786b710d015015049626f836dbba339 (plain)
1
2
3
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
Appends the specified stream entry to the stream at the specified key. If the
key does not exist, as a side effect of running this command the key is created
with a stream value. The creation of stream's key can be disabled with the
`NOMKSTREAM` option.

An entry is composed of a set of field-value pairs, it is basically a small
dictionary. The field-value pairs are stored in the same order they are given by
the user, and commands to read the stream such as `XRANGE` or `XREAD` are
guaranteed to return the fields and values exactly in the same order they were
added by `XADD`.

`XADD` is the _only Redis command_ that can add data to a stream, but there are
other commands, such as `XDEL` and `XTRIM`, that are able to remove data from a
stream.

## Specifying a Stream ID as an argument

A stream entry ID identifies a given entry inside a stream.

The `XADD` command will auto-generate a unique ID for you if the ID argument
specified is the `*` character (asterisk ASCII character). However, while useful
only in very rare cases, it is possible to specify a well-formed ID, so that the
new entry will be added exactly with the specified ID.

IDs are specified by two numbers separated by a `-` character:

    1526919030474-55

Both quantities are 64-bit numbers. When an ID is auto-generated, the first part
is the Unix time in milliseconds of the Redis instance generating the ID. The
second part is just a sequence number and is used in order to distinguish IDs
generated in the same millisecond.

IDs are guaranteed to be always incremental: If you compare the ID of the entry
just inserted it will be greater than any other past ID, so entries are totally
ordered inside a stream. In order to guarantee this property, if the current top
ID in the stream has a time greater than the current local time of the instance,
the top entry time will be used instead, and the sequence part of the ID
incremented. This may happen when, for instance, the local clock jumps backward,
or if after a failover the new master has a different absolute time.

When a user specified an explicit ID to `XADD`, the minimum valid ID is `0-1`,
and the user _must_ specify an ID which is greater than any other ID currently
inside the stream, otherwise the command will fail and return an error. Usually
resorting to specific IDs is useful only if you have another system generating
unique IDs (for instance an SQL table) and you really want the Redis stream IDs
to match the one of this other system.

## Capped streams

`XADD` incorporates the same semantics as the `XTRIM` command - refer to its
documentation page for more information. This allows adding new entries and
keeping the stream's size in check with a single call to `XADD`, effectively
capping the stream with an arbitrary threshold. Although exact trimming is
possible and is the default, due to the internal representation of streams it is
more efficient to add an entry and trim stream with `XADD` using **almost
exact** trimming (the `~` argument).

For example, calling `XADD` in the following form:

    XADD mystream MAXLEN ~ 1000 * ... entry fields here ...

Will add a new entry but will also evict old entries so that the stream will
contain only 1000 entries, or at most a few tens more.

## Additional information about streams

For further information about Redis streams please check our
[introduction to Redis Streams document](/topics/streams-intro).

@return

@bulk-string-reply, specifically:

The command returns the ID of the added entry. The ID is the one auto-generated
if `*` is passed as ID argument, otherwise the command just returns the same ID
specified by the user during insertion.

The command returns a @nil-reply when used with the `NOMKSTREAM` option and the
key doesn't exist.

@history

- `>= 6.2`: Added the `NOMKSTREAM` option, `MINID` trimming strategy and the
  `LIMIT` option.

@examples

```cli
XADD mystream * name Sara surname OConnor
XADD mystream * field1 value1 field2 value2 field3 value3
XLEN mystream
XRANGE mystream - +
```