Cassandra DB中的数据插入
是指将数据存储到Cassandra数据库中的操作。Cassandra是一个高度可扩展、分布式的NoSQL数据库，适用于大规模数据存储和处理。
数据插入是Cassandra中最基本的操作之一，可以通过CQL（Cassandra Query Language）语句来实现。CQL是一种类似于SQL的语言，用于与Cassandra数据库进行交互。
在进行数据插入之前，需要先创建一个表来存储数据。表由多个列组成，每个列都有一个名称和数据类型。可以根据具体的业务需求来设计表的结构。
数据插入可以使用INSERT语句来完成。INSERT语句指定要插入数据的表名和要插入的列及其对应的值。可以一次插入多行数据，每行数据使用一对小括号括起来。
Cassandra的数据插入具有以下特点和优势：
- 高度可扩展：Cassandra支持水平扩展，可以轻松处理大规模数据。
- 分布式存储：数据在集群中分布存储，提高了读写性能和容错能力。
- 弹性数据模型：Cassandra具有灵活的数据模型，可以根据需要动态添加、删除列。
- 高性能写入：Cassandra的写入性能非常高，适用于需要大量写入操作的场景。
- 容错性：Cassandra具有自动数据复制和故障转移的机制，保证数据的可靠性和可用性。
Cassandra中数据插入的应用场景包括：
- 大数据存储和分析：Cassandra适用于存储和处理大规模的结构化和非结构化数据，如日志数据、传感器数据等。
- 时序数据存储：Cassandra的分布式特性和高性能写入使其成为存储时序数据（如物联网设备数据、日志时间序列数据）的理想选择。
- 用户个性化推荐：Cassandra可以存储和查询用户的个性化偏好和行为数据，用于实现个性化推荐系统。
- 实时数据处理：Cassandra的高性能写入和低延迟查询特性使其适用于实时数据处理和流式计算场景。
腾讯云提供了Cassandra数据库的托管服务，称为TencentDB for Cassandra。它提供了高可用性、高性能的Cassandra数据库集群，支持自动扩展和备份恢复等功能。您可以通过以下链接了解更多关于TencentDB for Cassandra的信息：https://cloud.tencent.com/product/tcassandra
相关·内容
我有一个具有以下结构的Cassandra CQL3列家族
CREATE TABLE mytable(
A text,
B text,
C text,
mymap map<text,text>,
D text,
PRIMARY KEY (A,B,C)
);
我正在尝试使用Astyanax将大量数据插入其中。
我正在使用的Cassandra版本是1.2，所以我不能使用批处理插入。
我知道我可以使用准备好的语句在for循环中运行CQL3命令。
我想知道是否可以使用Astyanax突变批处理将数据插入到上面的列家族中？我意识到，这将利用AstyanAXTh裂缝接口插
浏览 1提问于2014-02-11得票数 1
回答已采纳
我使用cassandra stress来测试cassandra DB的性能。看起来cassandra DB的性能很棒。但是当我用select count(*) from table Name;检查有多少数据被插入到cassandra中时。我收到一个超时错误。有人知道怎么检查吗？
浏览 0提问于2017-04-19得票数 0
我正在尝试将XML数据插入到Cassandra DB中。有没有人能建议一下nifi中的流程。我有JMS，我需要在JMS上发布messagedata，然后将数据消费并插入到Cassandra中。
浏览 0提问于2017-07-24得票数 0
我使用Apache Nifi将DB2加载数据连接到Cassandra。我的Db2表有超过200+k的记录，但是只有400no被插入到cassandra target中。为剩余的cassandra批处理语句获取错误，不能插入超过65535条记录。尝试在yaml文件中进行一些更改，但没有帮助，得到相同的错误。我可以在Nifi中将批次更改为批量吗？或者，如果我需要从Db2加载所有记录，那么在Nifi或Cassandra中需要做哪些更改？
<code>B0</code>
<code>B1</code>
日志文件o/p
<code>A2<
浏览 16提问于2019-04-02得票数 0
1回答
我把cassandra表定义为：
CREATE TABLE db.table (
value text,
time timestamp,
sid text,
PRIMARY KEY (sid, time)
) WITH CLUSTERING ORDER BY (time ASC)
AND bloom_filter_fp_chance = 0.01
AND caching = '{"keys":"ALL", "rows_per_partition":"NONE"}'
浏览 0提问于2017-01-22得票数 5
回答已采纳
我想知道如何将数据从Cassandra导入Hadoop文件系统，以及如何定期执行此操作(即，当Cassandra DB发生更改或新数据插入Cassandra时，我们如何检测更改并将数据迁移到HDFS(Hadoop文件系统)？
浏览 1提问于2012-12-28得票数 1
我有一个使用Cassandra作为数据库的应用程序，我需要从Cassanbdra DB数据创建某种类型的报告，但是数据不是按照报表查询来建模的。因此，一份报告的数据可能分散在多个表中。由于Cassandra不允许像关系数据库管理系统这样的连接，这对do.So来说并不简单--我正在考虑一种解决方案，以实时获取其他DB ( RDBMS或Mongo)中所需的表数据，然后从那里生成报告。那么，我们是否有任何标准的方法来实时地将Cassandra的数据从Cassandra获取到其他DBs (Mongo或RDBMS)，即每当在Cassandra中发生插入/更新/删除时，也必须在目的地DB中执行eb更新。任
浏览 2提问于2022-01-18得票数 1
2回答
我有很多(大约一百万秒)结构化数据必须插入到数据库中，我看到了很多关于sql与noSql和Nosql类型的基准测试，然后收集了cassandra作为数据库。
但是我创建了一个基准测试来测试mysql与cassandra在写/更新/选择速度方面的性能mysql在我的基准测试中有更好的性能，我想知道我的错误是什么？？
php作为编程语言，作为php驱动，PDO作为mysql驱动
我的服务器是mysql 6.5，有2核CPU和2 2GB内存，centOS和cassandra有默认配置。
基准测试详情：
cassandra键空间和列族结构:创建test2 ={ 'class‘：'Sim
浏览 1提问于2014-09-03得票数 2
如何使用cassandra DB检索大数据。我用的是卡桑德拉1.1.7。有32 GB内存和1TB硬盘。成功的话，我可以将记录插入其中。当我试图检索数据的时候
例：
select * from table name (or) select count(*) from tablename;
Cassandra服务器可能崩溃或关闭(表包含有10列的300 k行)。
它显示错误：
调整yaml中的flush_largest_memtables_at_threshold大小或清除缓存大小
和JVM堆转储错误，它在pid-XXX.hprof文件夹中创建了cassandra/bin文件。
在cass
浏览 5提问于2014-07-03得票数 3
我已经在Cassandra中插入了大量数据。现在我想随机查询一条记录。但我不知道primary key。所以我想要一种在Cassandra中获取all data的主键的方法，然后我可以使用一个随机的主键来查询数据。
我可以从Cassandra的data目录中获得它吗？我只在那个目录中找到了.db文件。
浏览 16提问于2017-02-17得票数 3
1回答
我们在将数据从Cassandra导出到MySql数据库时面临问题。例如,
我使用cql在cassandra中创建了名为test_ks的键空间和名为test_cf的列家族。
我在test_cf中插入了一些虚拟数据，并在文件夹/var/lib/cassandra/data/test_ks/test_cf中创建了相应的文件，如下所示。
[root@balnsand01 test_cf]# pwd
/var/lib/cassandra/data/test_ks/test_cf
[root@balnsand01 test_cf]# ls -lrt
total 24
-rw-r--r-
浏览 1提问于2013-09-18得票数 0
我使用以下代码将预测结果保存到使用spark Cassandra连接器的Cassandra DB中：
CassandraJavaUtil.javaFunctions(sensorDataRDD).writerBuilder(modelParamter.keyspace, "sensor_data_2",
CassandraJavaUtil.mapToRow(SensorData2Double.class)).saveToCassandra();
数据基于以秒为单位的时间戳。因此，预测的写入可以按小时进行缩放。我需要先删除所有以前的记录。删除操作应
浏览 0提问于2017-06-22得票数 1
我已经在装有Cassandra 1.8的Linux m/c上安装了JDK2.2.5。
现在，我使用spring-cassandra-data jar中提供的CassandraTemplate在Cassandra DB中插入记录。
然而，时间戳被转换为GMT，即在存储到数据库之前从时间戳中扣除5:30小时。
Ex: TimeStamp passed is '2016-02-29 13:25:21'
and TimeStamp stored is 2016-02-29 07:55:21+0000
我希望实际的时间戳存储在数据库中。
提前谢谢。
浏览 0提问于2016-02-29得票数 0
我使用Cassandra2.0.3，通过加载文件(源代码命令)，通过cqlsh删除并重新创建一个简单的表。在同一个文件中，我在新创建的表中插入了一些行。
大约每3-4次尝试一次，我就会在一些插入项上得到rpc_timeout。在这种情况下，在集群的一个节点上总是有这个异常：
WARN [Thread-63] 2014-05-07 10:52:39,658 IncomingTcpConnection.java (line 83) UnknownColumnFamilyException reading from socket; closing
org.apache.cassandra.db.U
浏览 3提问于2014-05-07得票数 0
回答已采纳
我正在向cassandra迈出一些婴儿般的步伐，我想要一些建议。
我想要将数据插入到一个into列族中，我已经使用以下凭据创建了一个列族-
ColumnFamily: testkp
Key Validation Class: org.apache.cassandra.db.marshal.UTF8Type
Default column value validator: org.apache.cassandra.db.marshal.UTF8Type
Columns sorted by: org.apache.cassandra.db.marshal.UTF8Type
GC
浏览 0提问于2012-11-02得票数 0
我正在数据Stax的cassandra数据库中插入一个大约14k行的df。我使用的免费版本的Data，在那里，您有25 MB的存储限制。我的数据集大约是1.5MB大小。我的代码在插入和获取后没有出现错误。但是，在我计算了提取后的行数之后，我只得到了大约1.5k行。我似乎不知道问题出在哪里。是插入码还是取码？在绞尽脑汁并多次搜索谷歌之后，我无法弄清楚。以下是我的代码-：
cassandraDBLoad.py
def progressbar(it, prefix="", size=60, out=sys.stdout): # Python3.3+
count = len(i
浏览 19提问于2022-07-17得票数 0
1回答
目前我有两千万条记录，我想把它插入到我的Cassandra db表中。每条记录的大小约为1KB。
目前，我所做的是为每条记录创建一个PreparedStatement (com.datastax.driver.core)，并执行它(通过com.datastax.driver.core.Sessions)将数据传输到表中。
整个过程大约需要5到6个小时才能完成。对于cassandra，我有03个节点(使用HHD)。据我所知，我所做的是串行插入操作。
我的问题是，我能做些什么来加快整个插入过程？
浏览 0提问于2016-01-22得票数 0
我正在尝试将对规范化DB2数据库(托管在IBM大型机上)的所有插入、更新和删除操作同步到Cassandra数据库。在将这些更改写入Cassandra之前，我还需要反规范化这些更改，以便数据结构符合我的Cassandra模型。在google上搜索，但工具要么缺乏处理支持，要么缺乏流式CDC支持。有没有什么工具可以帮助我实现上述目标呢？
浏览 1提问于2015-10-22得票数 0
我已经将大量数据插入到两个节点cassandra服务器中。两天后，我发现服务器出现了这个错误，我猜不出问题所在
FSReadError in /var/lib/cassandra/data/system/hints/system-hints-jb-1090-Data.db
at org.apache.cassandra.io.compress.CompressedRandomAccessReader.reBuffer(CompressedRandomAccessReader.java:95)
at org.apache.cassandra.io.util.Ran
浏览 3提问于2013-10-03得票数 0
回答已采纳
5回答
我正在研究apache，并进行示例数据插入、检索等工作。
文件非常有限。
我有兴趣知道
我们能否用cassandra完全取代关系db，如mysql/ oracle？
cassandra支持回滚/提交吗？
cassandra客户端(节俭/赫克托)是否支持获取相关对象(将一个超级列的键保存在另一个超级列家族中的对象)？
这将极大地帮助我继续前进。
提前谢谢你。
浏览 3提问于2010-06-04得票数 36
回答已采纳
我使用Cassandra 1.1.1和Hector 1.0.5，试图将数据(大容量)插入到列族中。在我的程序执行期间，cassandra服务器崩溃并显示内存不足的错误.在此之后，我别无选择，只能退出服务器。这在一个列家族中被重复，我试图存储html文件的内容，但我从来没有机会完成它。html文件内容从225 KB数据到一行700 KB数据不等，我正在尝试插入将近1000条记录。
在程序中，它抛出以下内容
Exception in thread "main" me.prettyprint.hector.api.exceptions.HectorException: All ho
浏览 0提问于2012-07-05得票数 2
回答已采纳
我已经编写了以下JAVA方法，通过Apache Spark将多个POJO的数据持久化到Apache Cassandra数据库。
这看起来工作正常，但是Spark没有提供任何关于记录是否被插入(键在cassandra中不存在)或是否被更新(键已经存在于DB中)的信息。
有没有一种成本最低的方法(我想避免在数据帧中加载表的内容和检查重复的键)，以便在插入时找出数据库中已经存在的记录(具有重复的键)？
具体代码如下所示：
@Service
public class WriteDB {
@Autowired
private SparkSession sparkSession;
浏览 12提问于2019-11-01得票数 1
1回答
我试图确定是否使用PostGres或Cassandra数据存储。数据将首先通过以下方式插入到这个新存储区: 1.每天插入100 be的批处理过程。2.稍后，现有批处理+ CRUD操作以每秒20次操作的速度进行。
从阅读文章和与其他人的各种谈话中，我确定：
**Cassandra**
Type: NoSql
Read Speed: Fast
Write Speed: Slow
Storage: Distributed Cluster
Scaling: Horizontal
**PostGres**
Type: Relational
Storage: Single Instance
Scalin
浏览 11提问于2020-03-29得票数 0
回答已采纳
我已经生成了Microservice jhpister API，它使用cassandra作为db。我已经使用yo jhipster: entity entityname生成了实体。在生成字段时，我将字段CreatedOn的数据类型指定为ZonedDateTime。因此，它使用ZonedDateTime在cassandra表和java实体中创建TimeStamp作为数据类型。我有一些使用BindStatement的自定义插入代码
BatchStatement batch = new BatchStatement();
batch.add(insertStatement.bind()
.setTi
浏览 7提问于2017-02-02得票数 0
我想使用json2sstable选项将json数据插入到cassandra sstable中。
我的sstable是：
cid | key | ts
101 | ramu | 686
我想使用json放入另一行。
json文件是：
[
{"columns": [["cid","102"],["key","raju"],["ts","687"]]}
]
我正在运行以下代码：
D:\cassandra\bin>json2sstable -K demodb -c data_poin
浏览 2提问于2014-02-17得票数 0
我试图查询并将内容插入cassandra DB中。我知道如何在cql (cqlsh)的命令行中这样做，但不确定如何通过node.js与cassandra数据库进行基本交互。
如果有人能给我一个非常简单的代码示例，说明如何做到这一点，那将是非常有用的！
没有节俭，只允许使用node.js。
提前谢谢。
浏览 3提问于2014-03-05得票数 6
回答已采纳
我在我的项目中使用Spring数据Cassandra，我需要在Cassandra表中保存一个日期值，列类型在DB中是date，我可以在其中保存值，但是我不能将它设置为null。当我打电话给
CrudRepository ->save(obj)
，该字段中的数据未被删除。我尝试将bean中的date字段设置为null，然后调用save方法，它无法工作。
我想知道如何将日期值保存回空？
任何人都请帮忙。
谢谢。
卡桑德拉可以支持多次为同一记录插入。因此，我只需调用相同的方法来创建和更新。如果我使用cassandra来创建一个BoundStatement，请使用SQL "in
浏览 4提问于2015-08-21得票数 2
当数据被插入到表中时，我正在尝试立即读取cassandra表。该表将时间戳作为主键之一(而不是分区键)。我们有一个spark任务，每15秒读一次kafka，写一次cassandra。当spark作业开始插入数据时，服务器组件几乎立即从cassandra读取数据。由于插入到cassandra的数据非常庞大，我们正在分页读取数据。在阅读页面时，我们观察到很少有记录被跳过并到达最后一条记录。
但是，当我们在所有已插入的数据上运行按页读取数据的相同逻辑时，它工作得很好(没有跳过记录)。在cassandra中插入数据时，有没有办法读取分页的数据？
浏览 2提问于2016-05-13得票数 0
1回答
火花与卡桑德拉:界面的推荐方法
、、、、
我一直在使用从火花驱动程序中插入数据到卡桑德拉表。似乎也可以用于同样的用途。虽然对于像Cassandra这样的NoSQL DB来说，误用Spark中支持的来进行NoSQL数据建模似乎是错误的。
据我所知，我宁愿坚持使用Cassandra Java驱动程序。不过，我想知道我是不是漏掉了什么东西。
这是更有效的使用或更好的建议使用卡桑德拉。
相关问题-
浏览 2提问于2016-06-27得票数 1
回答已采纳
我正在进行单节点Cassandra设置。我使用的系统有4核cpu和8 8GB的RAM。我使用的柱族的属性是：
Keyspace: keyspace1:
Replication Strategy: org.apache.cassandra.locator.NetworkTopologyStrategy
Durable Writes: true
Options: [datacenter1:1]
Column Families:
ColumnFamily: colfamily (Super)
Key Validation Class: org.apache.c
浏览 2提问于2012-01-04得票数 1
2回答
现在，我有一个运行Cassandra的ec2实例和一个简单的websocket服务器。我想知道这是否是制作“实时”聊天应用程序的正确方法。我是不是漏掉了什么？
客户端连接到websocket，插入一条消息，该消息被存储到数据库中，如果记录到数据库成功，则将该消息发送给用户。
const cassandra = require('cassandra-driver');
const client = new cassandra.Client({ contactPoints: ['127.0.0.1'],
localDataCenter: 'datacent
浏览 3提问于2019-09-22得票数 7
通过利用Cassandra的文件级缓存、键缓存和行缓存，我们可以将Cassandra用作分布式内存缓存数据库吗？
我不想让每个节点过载，我想在数据增长时向集群中添加更多节点，以使其更有效(让我的大部分数据被缓存)。特别是因为我的列族中有40%是静态的，而且对其他表的更新/插入也不多。
我们的主要目标是需要一个弹性的实时数据存储(在内存dB中速度更快)
浏览 0提问于2014-10-31得票数 7
回答已采纳
1回答
我试图使用cqlsh将大量数据插入cassandra中的表中。在语言中是否有类似于(来自mongo )的东西：
for(var j=0; j<100000; j++) {
db.table1.insert({num: i, text: "txt"});
}
批处理和应用程序没有帮助，因为我想随机生成数据。
浏览 5提问于2016-10-31得票数 2
回答已采纳
1回答
利用Apache火花进行实时分析
、、、、
我使用Apache分析来自Cassandra的数据，并根据我们的查询在Cassandra中设计新的表，将数据插入Cassandra中。我想知道火花是否有可能实时分析？如果是，那怎么做？我读过这么多关于这方面的教程，但什么也没有发现。
每当数据立即进入我的表中时，我都想执行分析并插入Cassandra。
浏览 2提问于2015-03-31得票数 0
回答已采纳
我的配置
具有两个节点的集群：
Node 1:硬件:IntelXeon2.83 GHz (4核)，24 GHz内存，Dell虚拟磁盘SCSI 500 GHz
系统: Windows 2008 R2 x64
Java版本:7更新4 x64
Apache版本: 1.1.1Node 2:硬件:IntelXeon2.83 GHz (4核)，8GB内存，戴尔虚拟磁盘SCSI 500 8GB
系统: Windows 2008 R2 x64
Java版本:7更新4 x64
Apache版本: 1.1.1
Cassandra服务器配置：
heap size: 4 GB
seed_provider:
-
浏览 0提问于2012-06-13得票数 2
回答已采纳
我第一次尝试Cassandra，并为简单的会话管理db在本地运行它。卡桑德拉-2.0.4，CQL3，datastax驱动程序2.0.0-rc2
当表中没有数据时，以下计数查询工作良好：
select count(*) from session_data where app_name=? and account=? and last_access > ?
但是，即使将单个行插入到表中，查询也会失败，出现以下错误：
java.lang.AssertionError
at org.apache.cassandra.db.filter.ExtendedFilter$WithClauses.get
浏览 0提问于2014-01-22得票数 1
回答已采纳
5回答
卡桑德拉表现不佳？
、、、
我必须选择Cassandra或MongoDB(或另一个nosql数据库，我接受建议)作为一个插入量很大的项目(每天100万次)。因此，我创建了一个小测试来测量写性能。下面是在Cassandra中插入的代码：
import time
import os
import random
import string
import pycassa
def get_random_string(string_length):
return ''.join(random.choice(string.letters) for i in xrange(string_length))
de
浏览 5提问于2011-01-26得票数 8
回答已采纳
2回答
我正在尝试从Cassandra升级到最新的Datastax Enterprise，一切都很顺利，除了我无法找回我的数据。
基本上，我在升级后有了一个干净的cassandra，然后我重新创建了模式，并试图以某种方式将旧数据库遗留下来的文件链接到新数据库。
这就是我现在在/var/lib/cassandra/data/wowch目录中所拥有的，例如：
drwxr-x--- 4 cassandra cassandra 4.0K Feb 27 13:05 users-247834809d2011e58d82b7a748b1d9c2/
drwxr-xr-x 2 cassandra cassandra
浏览 0提问于2016-02-28得票数 0
我有一个如下所示的数据框架，并希望将此数据插入到cassandra表中
+---------+------+-----------+
| name | id | city |
+---------+------+-----------+
| sam | 123 | Atlanta |
| John | 456 | Texas |
+---------+------+-----------+
我使用下面的代码，但它只插入最后一行。
df.write.format("org.apache.spark.sql.cassandra")
浏览 0提问于2017-11-02得票数 0
1回答
我已经开始和卡桑德拉合作了。因此，我已经下载cassandra (1.1.1)到我的windows并启动它。一切都很好。因此，我开始重新实现一个旧的应用程序(在java中使用Hector1.1)，该应用程序为4个表导入大约200.000.000，应该将其插入到4个列家族中。导入约2.000.000条记录后，我得到一个超时异常，cassandra没有响应请求：
2012-07-03 15:35:43,299 WARN - Could not fullfill request on this host CassandraClient<localhost:9160-16>
2012-0
浏览 3提问于2012-07-03得票数 2
我最近一直在AWS中试用Apache Storm。我创建了一个SQS spout，它从SQS读取数据，并传递给一个Cassandra螺栓以插入到db中。当db插入成功时，确认消息被发回，并且消息从SQS中被删除。但是当并行度提示增加时，一条消息被插入多次。可能是因为在确认消息返回到spout之前，另一个线程已经从SQS读取了相同的消息。我该如何处理这种情况？如果没有并行性，速度会非常慢。
浏览 0提问于2015-11-27得票数 0
我有一些数据在卡桑德拉，这是动态的，并运行DSE 4.5在火花分析模式。
由于如果缓存的话，我无法保持RDD与底层数据库的同步，所以我需要一些后台进程来持续生成RDD并从DB收集最新的数据。
如何实现自动化，以便在Shell中每15分钟运行一次以下代码？(我对scala很陌生)
从cassandra表A创建RDD
变换它
保存到Cassandra表B
或者，我如何自动化，使我可以运行我的“插入与选择”命令在鲨鱼/火花sql连续每15分钟？
浏览 4提问于2014-12-18得票数 1
1回答
我正在使用Cassandra Python driver，我创建了一个表，在表中有一个列(称为date)被定义为timestamp。我尝试从dataframe访问值，并使用这些值将行插入表中。对应于date的数据格式(从PyCharm调试模式中捕获)，
Timestamp('2006-09-29 00:00:00')
但我发现了以下错误，
TypeError: Received an argument of invalid type for column "date". Expected: <class 'cassandra.cqltypes.Da
浏览 3提问于2016-06-15得票数 0
回答已采纳
我想将我的MySQL数据迁移到cassandra。我使用的是DSE的旧版本，即4.8，它支持sqoop命令。我的查询是，我希望插入具有动态timeuuid列值的行，该列值将在插入时生成，并且它不存在于MySQL表中。请帮帮忙。
我使用以下查询插入数据，但没有uuid列值。
bin/dse sqoop cql--导入--连接jdbc:// localhost :3306/ tbl1 -table -P -username root -P-cassandra-keyspace test -cassandra-table testtable -cassandra-host localhost-拆分-
浏览 2提问于2017-11-15得票数 0
回答已采纳
1回答
我在码头安装了卡桑德拉和气流。
我想使用气流在卡桑德拉表格中插入数据。
就像MySqlOperator在SQL表中安装数据一样，也没有任何操作符或方法将记录插入到Cassandra表中。
我只找到这两个操作符:从airflow.providers.apache.cassandra.sensors.record导入CassandraRecordSensor，从airflow.providers.apache.cassandra.sensors.table CassandraTableSensor导入CassandraTableSensor
但这些操作人员只是检查表格或记录卡桑德拉的存在。
那么，
浏览 1提问于2021-07-26得票数 0
回答已采纳
1回答
我希望建立一个实时pubsub数据库后端。RethinkDB实际上是我需要的一个完美的包，主要是因为它的changefeeds延迟非常低。但是RethinkDB似乎是一个在两台机器上每秒大约10k-20k插入的数据库。虽然我已经看到一些帖子声称人们在类似于Cassandra的数据库上每秒获得100万次插入，但Cassandra没有实时changefeeds功能。
所以我的问题是，有没有另一个DB或开源系统的组合，可以提供RethinkDB的低延迟更改馈送功能，但使其在比RethinkDB大得多的规模上发生？每秒插入的数量和订阅更改提要的用户数量都是需要尽可能高的重要要求。
浏览 0提问于2018-05-23得票数 0
1回答
我不得不使用JanusGraph从java程序中检索和添加数据。但是我不知道如何连接到db.Below的特定图形是我用来在数据库中插入数据的代码，但是当我尝试从gremlin控制台查看数据时，我找不到相同的数据。
JanusGraph graph = JanusGraphFactory.open("conf/janusgraph-cassandra-es.properties");
GraphTraversalSource g = graph.traversal();
graph.addVertex("psid",psid,"firstname"
浏览 11提问于2017-08-14得票数 6
回答已采纳
有没有用Cassandra替换传统RDBMS的ETL的成功实现？当我们将数据插入到Oracle或MySQL中时，有没有一种方法可以同时将数据插入Cassandra？
浏览 1提问于2015-05-18得票数 0
2回答
我有一个非常简单的Cassandra函数，在这个函数中，我连接到、Amazon和Cassandra数据库。Python中的这段代码可以工作，但有时我会收到错误。我该怎么纠正这种奇怪的行为？我假设您在初始化群集时需要进行额外的设置。例如，set_max_connections_per_host。我很感谢你的帮助。
错误：
('Unable to complete the operation against any hosts', {<Host: X.XXX.XX.XXX:XXXX eu-central-1>: ConnectionShutdown('Conne
浏览 6提问于2020-10-14得票数 2
我在AWS ec2上有两个实例。在其中一个实例中，我在docker容器中安装了Cassandra，现在我想从另一个ec2加载csv数据到Cassandra。那么，我是否可以直接将数据插入到Cassandra中，而无需将文件从一个ec2复制到另一个ec2(带有cassendra的ce2)？或者，我是否需要首先将文件复制到另一个ec2(带有cassendra的ec2)，然后再进行插入？ 我使用以下命令在docker中安装了cassandra： docker network create cassandra-net
docker run --name my-cassandra --network
浏览 12提问于2020-08-08得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
