Início / coding / Perguntas / 79562158
Accepted
vbulash
Asked: 2025-04-08 21:18:59 +0800 CST

Redigo: argumentos errados para XADD

  • 772

Gosto dos fluxos do Redis porque, com eles, o Redis se torna um banco de dados IoT. O principal comando do Redis para adicionar algo ao fluxo é XADD:

XADD log * name Some_name_to_write text Some_text_to_write

Funciona bem.

Então tento usar o Redigo para fazer a mesma operação:

type LogEntry struct {
    Name string `json:"name"`
    Text string `json:"text"`
}

func (l *LogEntry) Push() error {
    var args []string // XADD arguments

    log.Printf("Log Entry: %+v\n", l)
    args = make([]string, 6)
    args = append(args, "log") // Stream key
    args = append(args, "*")   // Auto-generated stream ID
    args = append(args, "name", l.Name)
    args = append(args, "text", l.Text)
    log.Printf("Args for XADD: %+v\n", args)

    new := make([]any, len(args))
    for index, value := range args {
        new[index] = value
    }

    _, err := connection.Do("XADD", new...)
    if err != nil {
        log.Println("XADD error", err)
        return err
    }

    return nil
}

connectionaqui está redis.Conn.

Este código produz a seguinte saída:

2025-04-08 16:03:08 2025/04/08 13:03:08 Log Entry: &{Name:Some_name_to_write Text:Some_text_to_write}
2025-04-08 16:03:08 2025/04/08 13:03:08 Args for XADD: [      log * name Some_name_to_write text Some_text_to_write]
2025-04-08 16:03:08 2025/04/08 13:03:08 XADD error ERR Invalid stream ID specified as stream command argument

Então, vejo que os argumentos são conn.Doexatamente os mesmos que usei antes na CLI.

O que há de errado aqui?

go

1 respostas

  1. Best Answer

    O problema está aqui

    args = make([]string, 6)

    Você está criando uma fatia de string com comprimento 6, mas quando você chama append nela, um novo item é adicionado à fatia. Isso significa que sua fatia agora tem comprimento 12, e não 6. (Ela tem 6 strings vazias no início, em vez dos comandos do Redis).

    Então, basta chamar make com 0 (ou simplesmente excluir a linha, pois a variável será declarada previamente).

    args = make([]string, 0)
    • 1

relate perguntas