如何使用Node.js驱动程序将REQ.Body的数据发布到CQL UDT列中？

Question

我是Cassandra的新手，我需要您的帮助。

使用CQL控制台创建收集表后，我能够创建新的记录并读取它们，但是使用nodejs中的Cassandra-Driver进行后操作不起作用，仅在使用CQL控制台时才有效。

我创建了表：

CREATE TYPE event_info (
    type text,
    pagePath text,
    ts text,
    actionName text
);

CREATE TABLE journey_info_5 (
    id uuid PRIMARY KEY,
    user_id text,
    session_start_ts timestamp,
    event FROZEN<event_info>
);

邮政操作的代码：

export const pushEvent = async(req,res)=>{
    const pushEventQuery = 'INSERT INTO user_journey.userjourney (id, user_id, session_start_ts,events)
    VALUES ( ${types.TimeUuid.now()}, ${req.body.user_id},${types.TimeUuid.now()},
     { ${req.body.type},${req.body.pagePath},${req.body.ts},${req.body.actionName}} } );'

    try {
        
        await client.execute(pushEventQuery)
       res.status(201).json("new record added successfully");

    } catch (error) {
        res.status(404).send({ message: error });
        console.log(error);
    }
}

它给出错误，如何从用户中获取数据并在此集合中发布？ 如果有的话，请帮助我

Answer 1

问题是您的CQL语句无效。用于在用户定义类型（UDT）列中插入值的格式是：

    { fieldname1: 'value1', fieldname2: 'value2', ... }

请注意，模式中的列名与您的代码中的CQL语句不匹配，因此我在此处重新启动架构，以确保

CREATE TYPE community.event_info (
    type text,
    pagepath text,
    ts text,
    actionname text
)

CREATE TABLE community.journey_info_5 (
    id uuid PRIMARY KEY,
    event frozen<event_info>,
    session_start_ts timestamp,
    user_id text
)

： CQL语句我用来将UDT插入表中（格式化以可读性）：

INSERT INTO journey_info_5 (id, user_id, session_start_ts, event)
  VALUES (
    now(),
    'thierry',
    totimestamp(now()),
    {
      type: 'type1',
      pagePath: 'pagePath1',
      ts: 'ts1',
      actionName: 'actionName1'
    }
  );

有关参考，请参见将数据插入或更新到UDT列。干杯!