Início / user-20266647

JIST's questions

Martin Hope
JIST
Asked: 2024-09-25 16:08:43 +0800 CST
  • 7

Tentei identificar o motor (Cassandra, Scylla, AstraDB, CosmosDB, Yugabyte, ...) com base na Cassandra Query Language (CQL). ​​Concentrei-me nas tabelas system.local e system.peers , veja o exemplo:

SELECT release_version FROM system.local;

e

SELECT release_version FROM system.peers;

mas não obtive informações relevantes sobre o sistema/motor. Você resolveu esse problema?

cassandra
Martin Hope
JIST
Asked: 2023-10-04 17:10:00 +0800 CST
  • 6

Usei o 'driver cassandra' padrão para acessar Cassandra e Scylla para inserir/atualizar dados via BatchStatement. Atualizei via lote 500 linhas e recebi apenas para Cassandra este erro (tudo funciona bem para Scylla):

Error from server: code=2200 [Invalid query] message="Batch too large"

Código Python, consulte:

from cassandra import ConsistencyLevel
from cassandra.cluster import Cluster
from cassandra.cluster import ExecutionProfile
from cassandra.cluster import EXEC_PROFILE_DEFAULT
from cassandra.query import BatchStatement

...
cluster = Cluster(contact_points=["localhost"],
                  port=9042,
                  execution_profiles={EXEC_PROFILE_DEFAULT: profile},
                  control_connection_timeout=60,
                  idle_heartbeat_interval=60,
                  connect_timeout=60)
session = cluster.connect(keyspace="catalog")
...
insert_statement = session.prepare(f"INSERT INTO rn6.t01 ({columns}) VALUES ({items})")
batch = BatchStatement(consistency_level=ConsistencyLevel.ONE)

data_frm = pandas.DataFrame(generator.integers(999999, 
                size=(run_setup.bulk_row, run_setup.bulk_col)),
                columns=[f"fn{i}" for i in range(run_setup.bulk_col)])

# prepare data
for row in data_frm.values:
    batch.add(insert_statement, row)

session.execute(batch)

Parece que Cassandra e Scylla têm limites padrão diferentes para instruções em lote. Você conhece esses limites?

python