如何在 Scylla 中获取特定分区键的流 ID

Question

我在 Scylla 有一张桌子

CREATE TABLE event (
    eventSource TEXT,        
    createdAt TIMEUUID,
    eventData TEXT,
    PRIMARY KEY (eventSource, createdAt)
) WITH cdc = {'enabled':true};

现在我希望使用 CDC

我知道流 IDCDC取决于生成和基表分区键，但是如何在不对 CDC 表进行全表扫描的情况下获取此流 ID？

是否有一些函数可以将给定的分区键转换为当前活动生成的流 ID？

Answer 1

这一切都记录在这里。

简而言之，有一个特殊的表来存储不同代的所有流。

你可以这样查询：

SELECT streams FROM system_distributed.cdc_description WHERE time = '2020-03-25 16:05:29.484+0000';

没有简单的方法可以找到 partition_key 的 stream_id。不过，它可以被逆向工程：

1. stream_id 是一个 16 字节的 blob。前 8 个字节是分配给此流的令牌的值。
2. 与此令牌位于同一 vnode 和分片中的所有分区键都属于此流。