草庐IT

cassandra-driver

全部标签

cassandra - 如何对Key-Value存储中的两个数据集进行交集运算?

假设我有2个数据集,一个用于规则,另一个用于值。我需要根据规则过滤值。我正在使用键值存储(couchbase、cassandra等)。我可以使用multi-get从一个表中检索所有值,并为另一个表检索所有规则,并在循环中执行验证。但是我发现这是非常低效的。我通过网络移动大量数据(值),而客户端忙于过滤。查找具有键值存储的两个表之间的交集的常见模式是什么? 最佳答案 nosql数据模型背后的想法是以非规范化的方式写入数据,以便表可以回答精确的查询。举个例子,假设您有顾客对商店的评论。您需要了解用户对商店的评论以及商店收到的评论。这将使

cassandra - 我不确定哪种 NoSQL 适合我的场景

我正在尝试设计创建一个基于云的系统(IaaS),该系统将从传感器(与水污染相关的事件)收集数据,并根据特定事件决定处理特定传感器的数据。数据特征是:1.对于每个传感器,数据每两天发送一次(每月最多6次)2.每个传感器读数包含大约5000个事件,这些事件封装在发送到服务器的50-100条消息中(这样的“session”大约需要20分钟,每5秒发送一次消息)3.我正在构建每秒处理30,000条消息的系统。4.数据的处理不应该是实时的,“session”结束后我有大约10分钟的时间来处理。5.90%的session没有意思,做完就可以扔掉。其他10%的事件或事件封装在消息中,根据它们我需要决

linux - 避免 php artisan 队列 :work : Queue Driver - Redis or Database (Laravel 5. 4)

我目前使用数据库作为我的队列驱动程序,我已经在Windows10PC上安装了Laravel5.4。为了处理队列,我一直在使用phpartisanqueue:work,这在开发阶段完全没问题。现在,该项目已完全准备就绪,需要部署在Linux服务器(专用)上我不确定如何避免在终端上运行命令phpartisanqueue:work以处理邮件作业?我已经在共享主机中部署过一次并且我使用了cron作业,但是现在我有专用服务器我想我应该可以使用其他东西来运行作业,我也在考虑使用Redis作为队列驱动程序而不是数据库作为队列驱动我需要一些关于什么是最好的建议。以及如何避免在专用服务器上使用phpar

concurrency - Cassandra 中的柜台设计

我正在尝试创建一个设计,其中多个C++服务将在数据库中保存计数器,如下所示:CREATETABLEpage_view_counts(url_namevarchar,counter_valuecounter,threshold_valueint,statusint,PRIMARY_KEY(url_name));我正在考虑使用Cassandra,但我不确定Cassandra是否可以以原子方式支持以下操作以支持多个服务实例的并发:READcounter_valueIFcounter_value>threshold_valueSETstatus=1(BLOCKED)ELSESETcounter

oplog.rs 上的 MongoDB C# Driver tailable 游标

我正在尝试使用类似于Java中实现的MongoDBC#驱动程序编写一个oplog观察器Here.到目前为止我已经设法写了:publicstaticvoidRead(){conststringconnectionString="mongodb://127.0.0.1:27017,127.0.0.1:27018/?replicaSet=rs0";MongoClientmongoClient=newMongoClient(connectionString);MongoDatabaselocal=mongoClient.GetServer().GetDatabase("local");Mong

java - 使用 Java Driver 询问 MongoDB host 是否为 Master

这个问题在这里已经有了答案:howtoexecutemongoadmincommandfromjava(3个答案)关闭9年前。是否可以询问MongoDB主机是否是使用Java驱动程序的主机?我检查了问题AskMongoDBifitisMasteroutofabashscript但我宁愿尝试在我的应用程序中执行此操作,也不愿在bash脚本中进行连接。

python monary 0.2.3 (mongo monary driver) : error in setup on windows 64bit (Anaconda distribution)

我读到有关python+mongo+monary对于numpypanda处理与mongodb一起工作的速度非常快AlexGaudio的博客http://alexgaudio.com/2012/07/07/monarymongopandas.html我正在尝试安装我从中获取的单一驱动程序https://pypi.python.org/pypi/Monary在Windows64位上。我有Anancondapython2.7发行版。python./setup.py安装我收到以下冲突错误。monary/cmonary.c:46:20:error:conflictingtypesfor'OBJE

c# - 带有字符串参数的 MongoDb c# Driver typed Builder

如何使用stringfieldname和value实现类型化的Builder,如以下代码所示:Builders.Filter.Eq(fieldName,value)我可以使用BsonDocument数据类型来实现它,但我需要检索类型化的ProfileFilterDifinition。 最佳答案 存在从string到FilterDefinition的隐式转换,因此您可以像以前一样使用它。例如:varprofile=awaitcollection.Find(Builders.Filter.Eq("Name","bar")).Single

java - 如何在 Mongo Async Java Driver 上实现多线程?

我正在尝试在Spring应用程序(没有Spring数据)上实现Inserts/Second的高吞吐量。我尝试使用以下代码插入一百万个文档:Addressaddress=newAddress();address.setStreet1("");address.setStreet2("");address.setZipCode("");address.setId(1234);StopWatchstopWatch=newStopWatch();stopWatch.start();IntStream.iterate(0,i->i++).limit(1000000).parallel().forE

c# - MongoDB C# Driver 2.1.0 - 解析引用

我在类之间有以下关系:publicclassPerson:Entity{publicstringFirstName{get;set;}publicstringLastName{get;set;}}publicclassProject:Entity{publicstringProjectName{get;set;}publicMongoDBRefLeader{get;set;}}我正在关注this使用以下代码段从MongoDbRef解析项目负责人的教程。不幸的是,我在C#2.1.0DriverforMongoDB中找不到类似于FetchDBRefAs()方法的东西varprojectCo