cqlsh控制台中的操作超时错误
我有一个三个节点cassandra群集,我创建了一个桌子,有超过2000,000行. 当我在cqlsh中执行此(select count(*) from userdetails)查询时,我得到了此错误: aperation timedout:errors = {},last_host = 192.168.1.2 当我以更少的行或限制50,000运行计数功能时,它可以正常工作. 解决方案 计数(*)实际上通过所有数据页面.因此,没有限制的一个select count(*) from userdetails将有很多行超时.这里有一些详细信息: http://planetcassandra.org/blog/blog/counting-key-key-key-inkey-in-cassandra/ 您可能要考虑自己维护数量,使用火花,或者如果您只想要一个球公园号码,则可以从JMX中获取. 从JMX中获取,根据您的数据模型,这可能有些棘手.要获得分区的数量,
22 2024-03-30
编程技术问答社区
通过CQLsh插入一个硬编码的UUID(Cassandra)。
想通过CQLSH脚本填充一些静态测试数据. 这不起作用:( device_id是uuid) insert into devices (device_id, geohash,name, external_identifier, measures, tags) values ('c37d661d-7e61-49ea-96a5-68c34e83db3a','9q9p3yyrn1', 'Acme1', '936', {'aparPower','actPower','actEnergy'},{'make':'Acme'}); 不良请求:无效字符串常数 (C37D661D-7E61-49E-96A5-68C34E83DB3A)用于uuid类型的设备 我似乎找不到任何CQL函数来转换为正确的类型.我需要从python脚本执行此操作吗? 谢谢 克里斯 解决方案 您不应该将引号周围放置在UUID周围以停止将其解释为字符串,即 insert into device
50 2023-11-12
编程技术问答社区
Cassandra复制命令-连接心跳失败
我在CQLSH中遇到以下错误.复制命令运行几秒钟,然后停止. 期待您的帮助. 谢谢, Connected to DRM at 127.0.0.1:9042. [cqlsh 5.0.1 | Cassandra 2.1.8 | CQL spec 3.2.0 | Native protocol v3] Use HELP for help. cqlsh> use myworld; cqlsh:myworld> copy citizens (id, first_name, last_name, house_no, street, city, country,ssn,phone,bank_name,account_no) from '/home/rashmi/Documents/MyData/Road/PeopleData-18-Jun-1.txt'; Processed 110000 rows; Write: 47913.28 rows/s Connection heartbea
48 2023-11-02
编程技术问答社区
指定cqlsh输出的时区
我在卡桑德拉(Cassandra)上有一个带有时间戳数据类型的表.我正在使用CQLSH将数据从数据库中获取,并希望更改我的时间戳列输出的输出格式.我研究了,发现我可以通过更改以下文件来更改时间戳输出格式: 〜/.cassandra/cqlshrc ,但我了解到,我唯一可以做出的更改是时间元素,我无法使输出以不同的时区(例如UTC)显示时间戳.它总是在我的本地时区显示时间戳. 我想知道我是否有一种方法可以在所需的时区或UTC区域至少进行CQLSH显示时间戳. 任何帮助或指示都将受到赞赏. 我正在使用以下版本: CQLSH 4.1.1 |卡桑德拉2.0.6 | CQL规格3.1.1 谢谢 解决方案 您可以更改环境变量以获取显示时区: TZ=America/Los_Angeles cqlsh -k mpj `hostname` -e 'select time from userbehavior limit 3' time ----------
32 2023-10-22
编程技术问答社区
Cassandra cqlsh-how to show microseconds/milliseconds for timestamp columns?
我要插入带有时间戳列的Cassandra表中.我带有微秒精度的数据,因此时间数据字符串看起来像这样: 2015-02-16T18:00:03.234+00:00 但是,在CQLSH中,当我运行选择查询时,没有显示微秒数据,我只能看到时间到第二精度. 234 微秒数据未显示. 我想我有两个问题: 1)卡桑德拉是否使用时间戳数据类型捕获微秒?我的猜测是? 2)如何与CQLSH看到它以验证? 表定义: create table data ( datetime timestamp, id text, type text, data text, primary key (id, type, datetime) ) with compaction = {'class' : 'DateTieredCompactionStrategy'}; 插入查询与java准备的启动: insert into data (datetime, i
28 2023-10-22
编程技术问答社区
Cassandra CQLSH OperationTimedOut error=客户端请求超时。见Session.execute[_async](timeout)
我想将数据从一个Cassandra群集(通过192.168.0.200到达)转移到另一个Cassandra群集(通过127.0.0.1到达).数据为523行,但每一行约为1 MB.我正在使用副本并复制到命令.当我发出副本命令时,我会遇到以下错误: Error for (8948428671687021382, 9075041744804640605): OperationTimedOut - errors={ '192.168.0.200': 'Client request timeout. See Session.execute[_async](timeout)'}, last_host=192.168.0.200 (will try again later attempt 1 of 5). 我尝试将~/.cassandra/cqlshrc文件更改为: [connection] client_timeout = 5000 但这没有帮助. 解决方案 尚不清楚您
228 2023-10-21
编程技术问答社区
Cassandra超时cqlsh查询大()量的数据
我正在进行一个学生项目,涉及建造和查询Cassandra数据集群. 当我的群集负载轻(大约30GB)时,我的查询毫无问题地跑了,但是现在它更大(1/2TB)我的查询正在计时. 我以为可能会出现这个问题,因此在我开始生成和加载测试数据之前,我在cassandra.yaml文件中更改了此值: request_timeout_in_ms (默认:10000)其他其他操作的默认超时. 但是,当我将该价值更改为1000000时,Cassandra似乎挂在创业公司上 - 但这本来可以是工作中的大时. 我的数据生成目标是2TB.我该如何查询那个很大的空间而不会遇到超时? 查询: SELECT huntpilotdn FROM project.t1 WHERE (currentroutingreason, orignodeid, origspan, origvideocap_bandwidth, datetimeorigina
66 2023-10-21
编程技术问答社区
Cassandra:无法从csv导入空值
我正在尝试将CS​​V文件导入Cassandra. CSV文件已从Postgres生成,它包含一些空值. 卡桑德拉版本: [CQLSH 5.0.1 |卡桑德拉3.5 | CQL规格3.4.0 |本机协议v4] 我正在使用此查询进行导入: 复制报告 (id,name,user_id,user_name,template_id,gen_epoch,exp_epoch,file_name,格式,repile_size,is_sch,job_id,status,status_msg) 来自'/home/reports.csv'with null =''and header = true and deLimiter = ','; 我继续收到此错误: 未能导入66行:parseerror- int()的文字无效 基础10:'',放弃没有重试 但是,当我将所有空值更改为某个随机值时,我能够使用同一命令导入该行.我已经尝试了在互联网上找到的所有解决方案. 请建议
52 2023-10-02
编程技术问答社区
无法通过cqlsh连接ssl节点
在解释我面临的问题之前,我会告诉您我本地机器的验证点. 我拥有所有与Cassandra相关的配置,并且我对机器具有所需的特权(访问). 我能够连接 ssl 禁用的cassandra节点,或通过 tls 通过 cqlsh禁用的节点 . 例如,我能够使用以下命令连接到下面的C*节点 cqlsh -u xxxxx -p xxxxxx 123.abc.com 但与此同时,我无法使用选项SSL 连接到以下节点 cqlsh --ssl -u xxxxx -p xxxxxx 123.xyz.com 以下是我对CQLSHRC文件的内容: [Authentication] Usename = xxxx password = xxxx [connection] hostname = 123.xyz.com port = 9042 factory = cqlshlib.ssl.ssl_transport_factory [ssl] certfile=~/certfiles/
24 2023-09-28
编程技术问答社区
gocql中的SSL选项
在我的Cassandra配置中,我启用了用户身份验证,并通过SSL与CQLSH连接. 我在使用GOCQL实现同样的情况下遇到了麻烦,以下是我的代码: cluster := gocql.NewCluster("127.0.0.1") cluster.Authenticator = gocql.PasswordAuthenticator{ Username: "myuser", Password: "mypassword", } cluster.SslOpts = &gocql.SslOptions { CertPath: "/path/to/cert.pem", } 当我尝试连接时,我会收到以下错误: gocql: unable to create session: connectionpool: unable to load X509 key pair: open : no such file or directory 在python中,我可
14 2023-09-27
编程技术问答社区
使用cqlsh与ssl
我已经在我的Cassandra节点中启用了SSL加密,我正在尝试弄清楚如何使用SSL使用CQLSH连接到我的节点: 当我运行./cqlsh --ssl时,我会收到以下错误: Validation is enabled; SSL transport factory requires a valid certfile to be specified. Please provide path to the certfile in [ssl] section as 'certfile' option in /root/.cassandra/cqlshrc (or use [certfiles] section) or set SSL_CERTFILE environment variable. 我遵循[authentication] username = fred password = !!bang!!$ 我要保留在根文件夹中,以便任何用户可以登录并可以访问公共文件夹(而不
22 2023-09-27
编程技术问答社区
弹簧数据cassandra像次级索引集群列上的查询一样
Java版本: openjdk version "20" 2023-03-21 OpenJDK Runtime Environment (build 20+37) OpenJDK 64-Bit Server VM (build 20+37, mixed mode, sharing) Springboot版本:3.0.1 卡桑德拉版本: cqlsh:hipi> SHOW version; [cqlsh 6.0.0 | Cassandra 4.0.7 | CQL spec 3.4.5 | Native protocol v5] 表描述 cqlsh:abc> DESCRIBE TABLE books; CREATE TABLE abc.books ( author_id text, name text, created_at timestamp, status boolean, PRIMARY KEY (author_id,
16 2023-09-13
编程技术问答社区
在cassandra中导入和导出模式
如何从Cassandra或Cassandra CQLSH提示中导入和导出模式? 解决方案 导出键空间架构: cqlsh -e "DESC KEYSPACE user" > user_schema.cql 导出整个数据库架构: cqlsh -e "DESC SCHEMA" > db_schema.cql 要在'user_schema.cql'('db_schema.cql')位置导入架构开放终端(或者您可以指定完整路径)和打开CQLSH shell.然后使用以下命令导入Keyspace架构: source 'user_schema.cql' 导入完整的数据库架构: source 'db_schema.cql' 其他解决方案 命令行直接的所有内容.无需进入cqlsh. 导入架构(.cql文件): $ cqlsh -e "SOURCE '/path/to/schema.cql'" 导出密钥空间: $ cqlsh -e "D
46 2023-08-21
编程技术问答社区
由于 python 属性错误,无法运行 cqlsh
无法在基于Mac M1的系统中执行命令CQLSH. % bin/cqlsh Traceback (most recent call last): File "/Users/avinashkasukurthi/devtools/apache-cassandra-4.0.7/bin/cqlsh.py", line 159, in from cqlshlib import cql3handling, cqlhandling, pylexotron, sslhandling, cqlshhandling File "/Users/avinashkasukurthi/devtools/apache-cassandra-4.0.7/bin/../pylib/cqlshlib/cql3handling.py", line 19, in from cqlshlib.cqlhandling import CqlParsingRuleSet,
18 2023-07-21
编程技术问答社区
Cassandra 3.11.3和cqlsh不支持python 3.6和3.7?
我已经安装了 python 3.6或3.7 ,用 cassandra 3.11.3 . 但是它不支持cqlsh,它仅支持 python 2.7 版本. 这是错误消息: \apache-cassandra-3.11.3\bin\\cqlsh.py", line 146 except ImportError, e: ^ SyntaxError: invalid syntax 可能是什么问题? 解决方案 cqlsh用py2.7编写,因此它不会在py3包装器上构建.即使您更改了异常行,也不会编译.例如,以这一行: File "/home/usr/.local/bin/cqlsh", line 212 print '\nWarning: Specified cqlshrc location `%s` does not exist. Using `%s` instead.\n' % (CONFI
30 2023-07-13
编程技术问答社区
不能用Python导出Cassandra表
我试图使用Python将Cassandra表将其导出到CSV格式.但是我做不到.但是,我能够从Python执行"选择"语句.我使用了以下代码: from cassandra.cluster import Cluster cluster = Cluster () session = cluster.connect('chandan') ### 'chandan' is the name of the keyspace ## name of the table is 'emp' session.execute(""" copy emp (id,name) to 'E:\HANA\emp.csv' with HEADER = true """ ) print "Exported to the CSV file" 请在这方面帮助我. 解决方案 这对您不起作用,因为复制不是CQL的一部分. 复制是一种仅CQLSH的工具. 您可以使用-e标志通过命令行或脚本调用此信
50 2023-07-05
编程技术问答社区
CQLSH client-module'对象没有属性'parse_options
我正在尝试通过CQLSH客户端访问我的Cassandra Server,以导入庞大的CSV文件.我遇到了module' object has no attribute 'parse_options错误. 我运行以下命令: cqlsh XXX.XXX.XX.XX XXXX --cqlversion="3.4.2" --execute="copy evolvdso.teste from '2016-10-26 15:25:10.csv' WITH DELIMITER =',' AND HEADER=TRUE --debug"; 这是以下的调试和错误消息: Starting copy of evolvdso.teste with columns ['ref_equip', 'date', 'load', 'ptd_assoc']. Traceback (most recent call last): File "/usr/local/bin/cqlsh", line
56 2023-06-30
编程技术问答社区
在运行COPY命令时出现腌制错误。Windows上的CQLShell
我们在Windows 7上的CQLShell中运行一个复制命令.首先,我们遇到了"不正确的复制命令": COPY ourdata(data_time, data_ID, dataBlob) FROM 'TestData.csv' WITH HEADER = true; 运行相同命令后,我们后来开始收到此错误: Error starting import process: Can't pickle : it's not found as thread.lock can only join a started process cqlsh:testkeyspace> Traceback (most recent call last): File "", line 1, in File "C:\Program Files\DataStax\Com
36 2023-06-27
编程技术问答社区
cqlsh连接错误:'ref()不接受关键字参数'。
I've tried all the measures from this post and cassandra doc . 我尝试运行所有版本的Cassandra,包括Tarball和Debian软件包的最新版本3.7,但是当我执行cqlsh>. 时,我会遇到错误. 错误: 连接错误:('无法连接到任何服务器',{'127.0.0.1':typeError('ref('ref()不使用关键字gragonments',)}) 我在将Cassandra运行之前没有问题,然后我将Linux Mint从17.3升级到18. 我相信我安装了所有必要的软件包,例如Java 8和Python 2.7.12. 我认为问题存在于cassandra.yaml文件中,因为默认设置不起作用,但是我不确定如何正确配置以使其运行. 任何提出的建议. 解决方案 您正在跑到 cassandra-11850 与Python 2.7.11+.该票已被标记为"解决",并且
126 2023-06-21
编程技术问答社区