主页 / user-5020510

Oleg Pro's questions

Martin Hope
Oleg Pro
Asked: 2024-12-23 23:03:42 +0800 CST
  • 6

我有从 docker-compose 运行的 Citus，我从官方网站获取了 yaml，并最初从 2 个节点运行它

 docker-compose -p citus up --scale worker=2 -d

之后我添加表格

CREATE TABLE IF NOT EXISTS messages (
                        text TEXT NOT NULL,
                       "from" CHARACTER VARYING NOT NULL,
                       "to" CHARACTER VARYING NOT NULL,
                       "shardId" CHARACTER VARYING NOT NULL
                  );

然后我调用SELECT create_distributed_table('messages', 'shardId'); shardId 来获取“from”和“to”变量的哈希值，范围从 0 到 31，到目前为止一切正常，我看到每个聊天都有自己的分片。

但当我尝试重新分片我的集群时

set POSTGRES_PASSWORD=pass && docker-compose -p citus up --scale worker=5 -d

并通过节点重新平衡数据

SELECT citus_rebalance_start();

我收到错误，说我无法在没有 pk 的情况下重新平衡表，因此我添加了一个 pk（id），然后我收到错误，说我无法将 create_distributed_table 的值设置为 pk 或在唯一约束下

  SELECT create_distributed_table('messages', 'shardId');

错误：无法对“消息”创建约束详细信息：分布式关系不能具有不包含分区列的 UNIQUE、EXCLUDE 或 PRIMARY KEY 约束（如果是 EXCLUDE，则使用相等运算符）。

所以我走进了死胡同，我该怎么做才能操纵 create_distributed_table 方法中的密钥？

postgresql
Martin Hope
Oleg Pro
Asked: 2024-02-29 21:10:12 +0800 CST
  • 6

我在托管我的应用程序的 kubernetes pod 上有一个环境变量列表，它没有任何部分，只有如下所示的变量列表：

KAFKA_BOOTSTRAP_SERVERS
KAFKA_PASSWORD
KAFKA_TOPIC
KAFKA_USERNAME

将其映射到我的选项类的最佳方法是什么

[ConfigurationKeyName("KAFKA_BOOTSTRAP_SERVERS")]
public required string BootstrapServers { get; set; }
[ConfigurationKeyName("KAFKA_USERNAME")]
public required string Username { get; set; }
[ConfigurationKeyName("KAFKA_PASSWORD")]
public required string Password { get; set; }
[ConfigurationKeyName("KAFKA_TOPIC")]
public required string Topic { get; set; }

我尝试通过IConfigureOptions<KafkaOptions>via 接口进行绑定，但它要求绑定 ConfigurationSection，而我没有

_configuration
     .GetSection(SectionName)
      .Bind(options);

谁能知道如何解决它？

c#