Início / user-5020510

Oleg Pro's questions

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

Eu tenho o Citus que executo no docker-compose, peguei o yaml do site oficial e o executei inicialmente em 2 nós

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

Depois adiciono a tabela

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
                  );

Eu chamo então um SELECT create_distributed_table('messages', 'shardId'); shardId que é um valor hash das variáveis ​​'from' e 'to' que variam de 0 a 31, até agora está tudo bem, vejo que cada chat tem seu próprio shard.

Mas então, quando tentei refragmentar meu cluster

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

e reequilibrar dados por meio de nós

SELECT citus_rebalance_start();

Recebi o erro de que não posso rebalancear a tabela sem um pk, então adicionei um pk(id) e então recebi o erro de que não posso colocar um valor create_distributed_table sendo um pk ou sob restrição exclusiva

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

ERRO: não é possível criar restrição em "mensagens" DETALHE: Relações distribuídas não podem ter restrições UNIQUE, EXCLUDE ou PRIMARY KEY que não incluam a coluna de partição (com um operador de igualdade se EXCLUDE).

Então estou em um beco sem saída. O que posso fazer para manipular a chave no método create_distributed_table?

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

Eu tenho uma lista de variáveis ​​de ambiente localizadas no pod do Kubernetes onde meu aplicativo está hospedado, não possui seções, apenas uma lista de variáveis ​​semelhante a esta:

KAFKA_BOOTSTRAP_SERVERS
KAFKA_PASSWORD
KAFKA_TOPIC
KAFKA_USERNAME

qual é a melhor maneira de mapeá-lo para minha classe de opções

[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; }

Tento vincular via IConfigureOptions<KafkaOptions>interface, mas é exigente ConfigurationSection para vincular, que não tenho

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

Alguém pode saber como resolver isso?

c#