重复的Siddhi分区或同一分区中的多个查询
是指在Siddhi流处理引擎中，由于错误配置或设计不当导致同一分区中存在多个重复的查询。
Siddhi是一种实时流处理引擎，用于处理流式数据，支持复杂事件处理和流分析。在Siddhi中，数据被划分为不同的分区，以便实现并行处理和提高性能。每个分区都可以包含一个或多个查询，用于定义对流数据的处理逻辑。
然而，当出现重复的Siddhi分区或同一分区中存在多个相同的查询时，会引发一些问题和挑战。首先，这种配置是多余的，会增加系统的复杂性并浪费资源。其次，重复的查询可能导致数据重复处理或重复输出结果，从而产生错误的计算结果。此外，当多个查询订阅相同的输入流时，可能会导致竞争条件和性能下降。
为了解决这个问题，我们可以采取以下措施：
- 审查和优化配置：仔细检查Siddhi配置文件，确保每个分区只包含必要的查询。删除重复的分区或查询，以减少冗余和混乱。
- 设计规范的查询逻辑：合理设计每个查询的逻辑，确保它们互不重叠，避免重复处理数据。合理使用过滤器、聚合操作和窗口函数等功能，以提高查询效率。
- 协调分区和查询：确保各个分区和查询之间的协调和协作。避免多个查询订阅相同的输入流，以避免竞争条件和数据重复处理。
- 监控和调优：使用适当的监控工具和技术，实时监控Siddhi引擎的运行情况。根据实际情况对查询进行调优，以提高性能和响应速度。
腾讯云提供的相关产品和服务包括腾讯云流计算SQC（StreamSQL）和腾讯云消息队列CMQ（Cloud Message Queue）。腾讯云流计算SQC是一项完全托管的流式数据处理服务，支持使用SQL语言进行实时数据分析和处理。腾讯云消息队列CMQ是一种高可靠、高性能的消息队列服务，可用于实时流式数据的传输和存储。
了解更多关于腾讯云流计算SQC的信息，请访问：腾讯云流计算SQC产品介绍
了解更多关于腾讯云消息队列CMQ的信息，请访问：腾讯云消息队列CMQ产品介绍
相关·内容
每当Siddhi检测到有航班进入Geofence时，我都会尝试让Siddhi触发事件，但找不到正确的查询来执行此操作。
我有以下输入流定义：
define stream GeofenceMulticasterConsumerStream ( journeyId string, geofenceId string, withinGeofence bool, timestamp long )
每次我得到一个航班的位置更新时，我都会得到一个在这个流中为系统中的每个Geofence生成的事件(大约有10个Geofence，所以我认为Siddhi应该能够处理10 *个位置更新事件)
这是我开始的查询：
浏览 0提问于2014-10-27得票数 0
2回答
您好:我有一个远程订阅事件频道的环境。事件通道将把事件推送到我的环境中，我将有许多规则来处理这些事件。我计划使用Siddhi框架来实现这些规则，并相应地处理事件。
在我查看了Siddhi代码库之后，似乎Siddhi执行模式在siddhi示例中得到了很好的表现，例如。它执行以下步骤：
(1)创建具有流查询的Siddhi运行时(查询1，查询2..)指定；(2)为输入流创建输入处理程序。(3)构造事件，然后使用输入处理程序发送事件；(4)创建的Siddhi Runtime添加回调，当输出流产生一些输出事件时，调用回调函数，传入输出事件。
通过简单的代码插入，我发现通过输入处理程序发送事件的线程与处理
浏览 3提问于2018-06-20得票数 0
1回答
在SiddhiQL中，如何能够在相同条件下插入多个流？
当我有两个相关事件(event1和event2)并希望在streamA中插入event1时；在streamB中插入event2；在streamC中插入abstractEvent。
我必须写三个Siddhi查询吗？
谢谢。
浏览 3提问于2016-02-05得票数 0
回答已采纳
3回答
如何从三个表中选择*？
、、、
我有三张桌子，场地，服务和vendorDetails。我想要获取所有表中的所有列。
我尝试在两个表上连接，但我得到了3次1条记录，得到了重复的记录。
查询：
SELECT venues.venueId,venues.venue_name,venues.latitude,venues.longitude,venues.active,services.serviceId,services.service_name,services.latitude,services.longitude,services.active FROM `venues`,`services` WHERE venues.ve
浏览 2提问于2016-08-11得票数 0
我们可以编写事件出现次数较少的Siddhi查询，条件如下 对于日志为'xyz‘、源为’customerId‘的3个事件，我们可以使用 from every (e1 = CargoStream[e1.customerId == 'xyz' AND e1.source = 'log']<3>) 但我们需要做的是在这3个事件之间添加条件。所有这三个元素应该具有相同的来源，而不是特定的值。 from every (e1 = CargoStream[e1.customerId == 'xyz' AND all these 3 even
浏览 14提问于2020-04-01得票数 0
我必须在我的项目POM中包含几个库，它们都是siddhi-extensions的子模块，就像下面的POM：
添加此依赖项如下所示：
Missing artifact org.wso2.siddhi:siddhi-extensions:jar:3.0.3.
<dependencies>
<dependency>
<groupId>org.wso2.siddhi</groupId>
<artifactId>siddhi-extensions</artifactId>
浏览 0提问于2017-02-19得票数 1
我对Siddhi CEP很陌生。我们计划使用它作为一个独立的java库。我们计划让SiddhiManager的一个实例使用不同的事件流，每个事件流都映射到一个带有查询的执行计划。
在下面的邮件线程中，提到了每个场景使用一个SiddhiManager实例。
因此，每个Siddhi Manager实例的执行计划数量是否有任何限制。
浏览 10提问于2015-10-19得票数 2
回答已采纳
1回答
我有以下流定义：
String eventStreamDefinition = "define stream cdrEventStream (nodeId string, phone string, timeStamp long, isOutgoingCall bool); ";
而问题是：
String query = "@info(name = 'query1') from cdrEventStream#window.externalTime(timeStamp,5 sec) select nodeId, phone, ti
浏览 8提问于2015-11-09得票数 0
回答已采纳
1回答
这是我的事件模式
EventA (FieldA string, FieldB string, FiledC string) EventB (FieldD string, FieldE string)
我希望查询如下：
将事件划分为组窗口、EventA组( FieldA, FieldB )、组EventB ( FieldE )
如果事件按以下顺序发生：EventA -> EventA -> EventA -> EventB -> EventB和distinct( EventA.FieldC ) >= 3，且每个EventB.FieldE等于每个
浏览 1提问于2017-01-06得票数 0
2回答
在测试wso2流处理器服务器的性能时，我在部署目录中放置了更多的.siddhi文件。这就导致了“许多打开的文件”问题。
我的规矩是：
所有的规则都听同样的卡夫卡主题。
每个规则都有自己的组id (因此它们都同时处理流)。
当部署文件夹中的.siddhi文件数量超过大约100个时。没有部署其他.siddhi文件，siddhi变得没有响应。
有谁能让我知道：
1.我到底哪里出了问题？
在单个siddhi服务器上创建规则的限制是什么？
浏览 0提问于2018-06-18得票数 0
1回答
我正在研究如何对数据集进行重新分区(在PySpark中)，以便将指定列中具有相同ID的所有行移动到相同的分区。实际上，我必须在每个分区中运行一个程序，该程序为具有相同ID的所有行计算单个值。
我有一个从HIVE QL查询构建的dataframe (df) (假设包含10000个不同的ID)。我试过了：
df = df.repartition("My_Column_Name")
默认情况下，我会获得200个分区，但在运行程序时，我总是会获得199个I，这些I的计算值是重复的。
我在网上看了看，有些人建议定义一个自定义的分区程序来使用repartition方法，但我不能找到如何在P
浏览 4提问于2018-05-22得票数 0
我在我的项目中使用Sidhhi CEP作为Java库。现在我需要使用High available system分析我的数据(类似于Esper HA)。我做了一些关于Siddhi高可用性的研究
也通过上面的链接
是否可以使用Siddhi java库来完成相同的任务？
浏览 3提问于2015-03-23得票数 0
1回答
我有一条小溪：
define stream locationStream (cell string, device string, power long);
我想在这个流中选择，有10秒的滑动窗口，对于每一个设备，“cell”属性的值是“power”最大的。
我应该使用什么查询来获得Siddhi的这个结果？有点像
from locationStream#window.time(10 seconds)
select max(power), device, <cell where power = max(power)>
group by device
insert all events
浏览 2提问于2017-09-04得票数 0
回答已采纳
假设我有下表-
itemA | itemB | relationScore | type
----------------------------------------
"s" | "a" | 1.0 | "foo"
"s" | "b" | 1.0 | "bar"
...
在这里，itemA + itemB是每行唯一的，我将它们分别设置为散列键和范围键。
但是，我的查询需要我去取所有的东西，这样-
itemA等于(A，B，C，D…)之
浏览 4提问于2020-09-30得票数 0
1回答
根据docs ()，您可以在分布式模式下运行Siddhi。
正如我所理解的那样，所有节点都将共享流定义并在共享上下文(流、查询、事件.)上操作。
但我不能让它起作用：
使用2.0.0-wso2v4版本
我编写了一个简单的程序，在启用分布式处理的情况下启动两个siddhiManagers。
该程序在siddhiManager1中创建流和查询。
添加一个流回调，在两个管理器(前一个流)中打印事件。
在siddhiManager1中发送事件
在siddhiManager1和siddhiManager2中打印流
结果是：
我能看到黑兹尔卡斯特在工作，每个经理都看到了
浏览 1提问于2014-04-04得票数 0
在siddhi中有很多回调，我想知道它们之间的区别。比如，我们什么时候应该使用streamCallback，什么时候我们应该使用queryCallback。
我找不到任何有关这方面的文件。
谢谢。
浏览 0提问于2015-11-20得票数 1
我有一些关于编写自定义OutputAttributeProcessor的问题。我使用WSO2 CEP2.1.0和Siddhi1.1.0。
我想要创建一个定制的OutputAttributeProcessor，所以我创建了两个java类，TestFactory实现了OutputAttributeProcessorFactory，测试实现了OutputAttributeProcessor。两个类的包是org.wso2.siddhi.extention。
TestFactory必须重写createAggregator和getProcessorType，测试必须重写createNewInstance、
浏览 1提问于2013-11-06得票数 1
回答已采纳
在Siddhi中，是否可以检索导致对查询做出积极响应的实际事件。
例如，如果我有一个事件A，它导致一个条件得到满足，我可以通过查询投影使我希望在ExecutionRuntime回调中使用的事件A的属性可用(作为Siddhi核心事件)。
但是，我希望检索满足查询的实际事件对象。而不仅仅是它的部分/全部属性，因为我想使用这个完整的事件作为进一步处理的一部分。这个是可能的吗？
如果可能，在需要多个事件来满足复杂查询(模式/序列)的情况下，我是否也能够返回事件。
提前感谢您的帮助。
浏览 3提问于2016-09-21得票数 0
回答已采纳
4回答
删除非重复行
、、
我有一个表，它有一个惟一的非聚集索引，这个索引中列出了4列。我想更新表中的大量行。如果我这样做了，它们将不再是不同的，因此更新会因为索引而失败。
我想禁用索引，然后删除最旧的重复行。到目前为止，我的查询如下：
SELECT t.itemid, t.fieldid, t.version, updated
FROM dbo.VersionedFields w
inner JOIN
(
SELECT itemid, fieldid, version, COUNT(*) AS QTY
FROM dbo.VersionedFields
GROUP BY itemid, field
浏览 1提问于2011-08-03得票数 7
回答已采纳
1回答
我们有一个场景，在Cassandra中，对于下面的模式，每次插入都发生在给定id_1的每个id_2上：
CREATE TABLE IF NOT EXISTS my_table (
id_1 UUID,
id_2 UUID,
textDetails TEXT,
PRIMARY KEY (id_1, id_2)
);
单个POST请求正文包含多个id_2值的详细信息。这会在单个表上触发每个POST请求的多个插入。
每个插入查询的执行方式如下所示：
insertQu
浏览 3提问于2021-04-28得票数 0
[2020-05-06_16-31-42_744] ERROR {com.zaxxer.hikari.pool.HikariPool} - HikariPool-32 - Exception during pool initialization.
java.sql.SQLException: The server time zone value 'unknown' is unrecognized or represents more than one time zone. You must configure either the server or JDBC driver
浏览 8提问于2020-05-06得票数 1
回答已采纳
我使用WSO2 API Managet 2.6.0作为我的Spring Boot REST API前面的API网关。
我想添加一个自定义限制策略来设置每个最终用户ip地址的速率限制，它是由面向互联网的网站管家放在请求头X-Forwarded-For中的。
WSO2文档显示了用Siddhi语言编写的自定义策略的一些示例，但它没有足够的示例。
我能找到的最详细的文章是，它展示了一个使用userId进行速率限制的例子。
FROM RequestStream
SELECT userId, userId as throttleKey
INSERT INTO EligibilityStream;
FR
浏览 0提问于2020-11-13得票数 1
2回答
是否有一种方法可以检测和报告流中的重复项？
示例:包含具有用户名和IP地址的元组的用户登录数据流。目标是检测最近10秒内来自不同IP的同一用户的登录。
我看过siddhi (wso2)和esper查询语言，但我不知道如何实现这一点。
浏览 1提问于2013-07-13得票数 2
回答已采纳
1回答
嗨:我需要在Siddhi流处理中实现以下重复数据消除逻辑。假设我有一个InputStream，并且我想生成如下OutputStream：
(1)当事件是InputStream中的第一个事件时(事件处理引擎启动后)，在OutputStream中插入该事件。
(2)如果具有相同签名的事件，例如相同的事件名称，在2分钟的窗口内到达，我们认为该事件是相同的，我们不应该在OutputStream中插入该事件。否则，我们应该将事件插入到OutputStream中。
我尝试使用事件模式来进行过滤。但是，我没有发现我可以用Siddhi表达“否定逻辑”，也就是if (not ( e1 --> e2 wit
浏览 6提问于2018-06-15得票数 0
我有大约100 to的数据需要回填，方法是运行查询来转换字段，然后将转换写到另一个表中。此表通过摄入时间戳进行分区。我将这两个操作作为单个查询的一部分，如下所示。我计划通过摄入时间戳范围，以较小块的方式多次运行此查询。
是否有更好的方法来处理这个过程，而不是在手动块中运行查询？例如，可能使用Dataflow或其他框架。
CREATE TABLE IF NOT EXISTS dataset.table
PARTITION BY DATE(timestamp) AS
with load as (SELECT *, _TABLE_SUFFIX as tableId
FROM `project
浏览 0提问于2018-07-24得票数 0
回答已采纳
我希望使用batch语句从数据库中的3个表中删除一行，以确保原子性。分区键在所有3个表中都是相同的。在我所读到的关于批处理语句的所有示例中，所有的查询都是针对一个表的？在我的例子中，使用批处理语句是个好主意吗？或者，我应该避开它吗？
我使用Cassandra-3.11.2，并使用C++驱动程序执行查询。
浏览 0提问于2018-03-19得票数 11
回答已采纳
根据，分区表可以有2500个分区：
每个分区表的最大分区数- 2,500
然而：
$ bq query --destination_table grey-sort-challenge:partitioning_magic.nyc_taxi_trips_partitioned --time_partitioning_field pickup_datetime --use_legacy_sql=false "select * from \`grey-sort-challenge.partitioning_magic.nyc_taxi_trips\`"
查询字符串中的错误:
浏览 0提问于2018-03-28得票数 3
回答已采纳
我正在使用siddhi创建一些应用程序，它也与PostgreSQL DB交互。虽然我不确定，但我相信，在同一个PG表中，在单个事件中(即在接收到一个事件时，在表中更新记录，并在同一个表中再次创建另一个记录)，对同一个PG表进行多个更新有一个错误，似乎批处理更新导致了一些问题。所以，我只想在禁用batchUpdate之后试一试(默认情况下是启用的)。我只是不知道如何使用siddhi-sdk (通过Intellij插件)来配置它。有两个相关的票证： ，直到这些记录被记录下来，我想得到一些快速响应如何设置这些字段。
最诚挚的问候..。
浏览 0提问于2018-04-04得票数 0
回答已采纳
我正在使用来自Cassandra的DataStax Nodejs驱动程序，我想要做的是避免在我的应用程序中插入非常频繁的I/O操作。我将每秒执行大约1000个插入，并希望将所有这些数据组合在一起，执行1个I/O，而不是运行将导致1000个I/O的单个查询。我看到了这样的批处理声明，
const query1 = 'UPDATE user_profiles SET email = ? WHERE key = ?';
const query2 = 'INSERT INTO user_track (key, text, date) VALUES (?, ?, ?)';
浏览 3提问于2018-03-23得票数 1
回答已采纳
如果在dynamodb表上执行"get_item“操作，则必须提供分区(主)键。不允许在GSI (全局辅助索引)上执行"get_item”操作，即使通过它执行的操作与分区(主)键完全相同。要使用GSI，需要“查询”数据库.。
所以，我的问题是：对于GSI来说，带有“等于”运算符的“查询”操作与分区键的"get_item“操作一样有效吗？
浏览 6提问于2020-05-07得票数 0
我是第一次接触cosmos db。我选择cosmos db (core sql)，创建了一个包含两个容器EmployeeContainer和DepartmentContainer的数据库。现在，我想查询这两个容器，并获取员工的详细信息和相关的部门详细信息。我坚持自己的观点，需要帮助。
下面是我的容器的结构。
EmployeeContainer : ID，Name，DepartmentID
DepartmentContainer: ID，名称
提前谢谢。
浏览 1提问于2020-06-22得票数 2
1回答
假设我有一张桌子 RecordingsByAccountaId ( AccountId，a，b，c，x，y，z) 分区键: AccountId集群键: a，b 我需要在我的代码中获取一个帐户的数据，所以执行 Select * from RecordingsByAccountaId where accountId = 'accountId'； 这是一个昂贵的手术吗？ 目标是更新这个表的2-3行，但除了accountId，我没有更多的信息。 查询一行还是整个分区几乎是一样的？因为我看到取200行n一行的时间相差20-30毫秒？
浏览 13提问于2020-01-30得票数 1
我有一个带有分区键(UUID)的DynamoDB表，它有一些属性(如名称、电子邮件、创建日期等)。创建日期是项中的属性之一，其格式为YYYY DD。但是现在有一个需求更改--我必须根据创建的日期对其进行排序，并将整个数据(也就是说，我不能只将数据放在特定的分区上，而是以一种排序的方式从所有分区中获取整个数据)。我知道，作为DynamoDB，从所有分区获取数据并对其进行排序可能需要一些时间。我的问题是：
用当前的设计可以查询吗？我可以在查询中看到分区键是必需的，这就是为什么我感到困惑的原因，因为我不能在这里提供分区键。
是否有更好的方法为这样的用例重新设计表？
提前谢谢。
浏览 2提问于2021-02-03得票数 0
我不熟悉WSO2、CEP和Siddhi查询。我已经创建了三个不同的事件流，每个流都与一个特定的传感器有关，如下图所示：
传感器的每个事件流都有传感器的纬度和经度。传感器放置在不同的坐标上，我想比较/关联它们的坐标(纬度和经度)。如何通过Siddhi查询比较它们的坐标(坐标变化不超过4米)？非常感谢!
浏览 10提问于2017-03-13得票数 0
回答已采纳
我目前使用的是Java servlet，它具有siddhi核心、api和查询jar库。我使用SiddhiManager类来创建流、查询和回调。servlet允许我运行常规查询，但不会查询基于时间窗口的查询，例如-
从StatusTime#window.time(4分钟)中选择cid，SUM (值)作为SUM组通过cid将(SUM>40)插入到payt中
每次调用servlet时，时间窗口都会重新启动，导致基于时间的查询失败。如何使siddhi管理器使用先前启动的时间窗口。
浏览 1提问于2015-07-27得票数 0
我在DynamoDB中创建了一个表“分数”来存储游戏的分数。
该表具有以下属性：
uuid
用户名
得分
日期时间
现在我想查询游戏的“前十名”分数(排行榜)。
在DynamoDB中，不可能在没有分区键的情况下创建索引。
那么，如何以可伸缩的方式执行此查询呢？
浏览 0提问于2018-01-14得票数 2
我正在使用Siddhi 1的Java库，并注意到在检索和处理由Siddhi运行时生成的事件方面存在相当大的延迟。虽然两个Siddhi事件可能具有时间差X秒的Siddhi事件时间戳，但在接收Siddhi事件时生成的相关应用程序级时间戳是在同一秒钟内生成的。为了说明这一点(所有时间戳都被裁剪为秒)：
1571059612Siddhi事件1时间戳：1571059617Application事件2时间戳: Siddhi事件1接收1571059617Application时间戳
应用时间戳是正确的，即Siddhi事件传播被延迟。此外，通过将应用程序时间戳设置为等于Siddhi事件时间戳来验证Siddhi
浏览 0提问于2019-10-15得票数 0
我计划使用DynamoDB，它的数据需要与CloudSearch同步。我知道Lambda是可以使用的，但是我想用Kinesis来实现它。因此，生产者是DynamoDB，它将为表中的每个PUT/DELETE生成流的数据。
我的设计非常直截了当：(假设消费者有序地接收记录)
接收记录
同步到CloudSearch
(重复)
当多个碎片存在时，我遇到了一些问题，弄清楚KCL如何确保在客户端有序交付记录。从API文档中，我了解到
我们需要使用GetShardIterator创建每个切分迭代器
有了那个碎铁器，我就可以在一个特定的序列中得到这个碎片的所有项目。
但是，
浏览 3提问于2017-08-04得票数 0
1回答
我正在从一个在Server上有大约400个连接的表中进行select，每个连接选择这个表的一部分并写入一个文件；select语句使用表上的索引，每个连接独立运行2.5分钟。当我尝试使用nolock运行400个类似的查询时，总查询时间增加到40分钟。有人知道我可以在哪里进行优化，以便将400查询的速度提高到与运行一个查询相同的速度吗？
为了更好地解释，下面是查询的示例：
SELECT * FROM TABLENAME WITH (NOLOCK) WHERE Id BETWEEN 0 AND 1999999
SELECT * FROM TABLENAME WITH (NOLOCK) WHERE
浏览 0提问于2018-06-27得票数 0
回答已采纳
考虑到伸缩性，我想知道查询是如何在KSQL服务器之间分布的？
1-假设您有cli或合流控制中心，cli是连接到所有服务器还是其中之一？它是否可以将查询发送到多个KSQL服务器，例如具有相同id (即池id)的服务器？
2-我们可以在多个KSQL服务器上运行同一查询的多个实例吗？如果是，那么它是如何工作的，例如，对于消费者组或分区？
3-我们可以在同一KSQL服务器上运行同一查询的多个实例吗？
浏览 0提问于2019-07-06得票数 0
下面是一个简化的场景：
N需要来自同一源的相同原始数据的业务流。这些数据使用Kafka (普通Kafka管道)进行采集，并降落在HDFS上，在HDFS上，每个流量的原始数据都会触发质量检查的自动流程。所有的N流都可能有不同的数据质量标准。例如，它们可能要求在将原始数据转换到所需的模式时，可以将日期和时间的不同格式应用于原始数据。
--处理未能满足业务流程质量测试的KPI的最佳方法是什么？
备选方案如下：
失败-通知源数据提供程序并等待固定数据。然后重新摄取和运行所有的N套质量检查.
创建一个分支--这意味着N个业务流程中没有通过质量检查的K将等待它们的固定数据集，而通过的N将与当前的数
浏览 2提问于2017-04-27得票数 0
我正在more 2014中运行以下查询，并且使用CTE技术而不是第一种技术获得更多的重复查询。
(可能是不必要的背景:这是一个大型表格，由病人相关数据组成，查看手术后30天内的住院情况。因此，重复行的条件包括接纳标识符"admitPK“和过程标识符"procedurePK")
第一方法：
SELECT [admitPK]
FROM db.table
GROUP BY [admitPK], [procedurePK]
HAVING COUNT(*) >1
CTE方法：
WITH dupes as (
SELECT *
,ROW_NUMBER() OV
浏览 1提问于2016-02-22得票数 3
我的用例-我想在我的Siddhi查询中使用存储的数据。 为此，我考虑使用Siddhi表概念来为我存储的数据提供抽象。 但是，我存储的数据可以通过REST api获得。我知道您可以插入外部数据库作为Siddhi表的源，是否也提供了插入REST api作为数据源？ 提前谢谢。
浏览 18提问于2019-01-15得票数 0
是否可以在siddhi上使用javascript扩展来查询内存中的表或其他数据库？ 我的函数需要识别b-tree数据结构中的所有元素。 谢谢。
浏览 25提问于2019-02-19得票数 0
我有一个DynamoDB表，其中有：
时间戳(散列)
文本(字符串)
我希望能够通过查询获得最新的项，但是这样做需要我按照Timestamp进行排序，而不是按它进行分区。我正考虑这样做：
分区(散列，硬编码为任何形式)
时间戳(范围)
文本(字符串)
这样我就可以查询并传递一个硬编码的分区。
但这是不好的做法吗？
浏览 2提问于2018-08-03得票数 1
2回答
与python消费者的多重处理
、、、、
我试图在python中开发一个包含一个主题(演示-主题)和一个分区的应用程序。在这个主题中，消息是随机推送的，我有一个使用者(consumer1) (演示组)，它使用这些消息进行一些背景计算(这需要一些时间)。
在amazon上使用这个应用程序，我希望能够按新创建的机器将同一组(演示-组)中的另一个使用者(使用者2)在同一个主题(演示-主题)中读取的方式来扩展它(当计算耗时很长时)，但以他们开始拆分负载的方式(消费者1需要一些负载，而消费者2接受其余的，但他们从来没有得到相同的消息)。
在数据激增停止后，第二台机器被停用，消费者1再次承担所有负载。
这是否可以执行(不需要在提交更多分区之前添加
浏览 2提问于2017-10-18得票数 0
3回答
我的数据集只会被直接查询(这意味着我正在通过某个标识符查找特定的项)，或者会被完整地查询(意思是返回表中的每一项)。既然如此，是否有理由不使用唯一的分区键？
根据我所读到的(例如：)，非唯一分区键的优点是能够进行事务性更新。我不需要在这个数据集中进行事务更新，所以除了某些独特的东西(例如，GUID)之外，还有什么理由来进行分区吗？
假设每个项目都有一个唯一的分区键，这意味着每个分区将有一行。是在行键中重复分区键，还是只为行键保留一个空字符串？允许空行键吗？
浏览 1提问于2015-09-07得票数 1
回答已采纳
1回答
定义流时，siddhi查询语言中是否允许使用布尔类型？通过查看Siddhi versión310 "“的语言模型，似乎不支持流布尔属性类型。它们只允许: int、long、double、float、string、time类型。
浏览 1提问于2015-06-02得票数 0
我有一个大表，它的行定期从几个不同的查询中得到更新/插入/合并。我需要一个计划好的进程来运行(通过API)，以定期检查自上次检查以来该表中哪些行被更新。所以我的问题是..。
当我运行合并查询时，我看不出它返回哪些记录被更新.否则，我可能会将更新后的行复制到一个特殊的updated_records表中。没有触发器，因此无法以这种方式跟踪突变。--我可以添加一个last_updated时间戳列来保持这种方式的跟踪，但随后整天重复查询该表，这将是大量的数据计费(昂贵)。
我想知道我是否忽略了一些显而易见的东西，或者也许有某种特殊的烧烤元数据可以帮助我吗？
我尝试这样做的原因是，我希望提取这个表的一个
浏览 11提问于2020-02-19得票数 1
回答已采纳
我正在尝试创建一个siddhi应用程序，当一个人接近某些预设位置时，它会添加输出。这些位置存储在数据库中。到目前为止，输入是从邮递员发出的。
但我一直收到错误，说数据类型不是'double‘。我甚至检查了表的详细信息，mysql表中的数据类型设置为double。
以下是siddhi代码和错误的详细信息。有没有人能给我指引一下。
siddhi扩展的位置：
Siddhi代码：
@App:name('ShipmentHistoryApp')
@source(type = 'http', receiver.url='http://localhost:5
浏览 0提问于2018-02-28得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
