结合使用流分析和SQL触发器
，可以实现实时数据处理和自动化操作。
流分析是一种实时数据处理技术，用于对数据流进行实时的筛选、转换和聚合操作。通过将数据流导入流分析系统，可以实时分析和处理数据，以便快速响应和适应不断变化的业务需求。流分析常用于监控和报警、实时数据分析、反欺诈、实时推荐等场景。
SQL触发器是一种在数据库中定义的特殊程序，当数据库中的某个事件（如插入、更新、删除）发生时，触发器会自动执行相应的操作。通过在触发器中编写SQL语句，可以实现对数据的自动化处理和操作，比如数据同步、数据验证、数据修改等。
结合使用流分析和SQL触发器可以实现以下功能：
- 实时数据处理：使用流分析对数据流进行实时筛选、转换和聚合，实现对数据的实时处理和分析。
- 实时报警和监控：通过流分析和SQL触发器，可以实时监控数据流中的异常情况，并触发相应的报警操作。
- 数据同步和备份：通过触发器在不同的数据库之间同步数据，实现数据的实时备份和同步。
- 数据验证和修正：使用触发器对数据进行验证和修正，确保数据的准确性和完整性。
- 自动化操作：通过触发器对数据进行自动化操作，如自动计算、自动修改等。
腾讯云相关产品推荐：
- 腾讯云流数据计算（Tencent Cloud Streaming Compute）：提供基于Flink和Kafka的实时数据处理和流分析服务，支持高吞吐、低延迟的数据处理需求。详情请见：腾讯云流数据计算
- 腾讯云数据库触发器（TencentDB Trigger）：支持在腾讯云数据库中定义触发器，实现对数据的自动化处理和操作。详情请见：腾讯云数据库触发器
以上是结合使用流分析和SQL触发器的概念、优势、应用场景以及腾讯云相关产品推荐。希望对您有帮助！
相关·内容
1回答
我正在尝试使用Azure流分析将数据从源移动到SQL Server。我想要执行一个存储的过程来正确地将数据放入SQL Server，所以我实现了一个触发器，它在SQL目标表上执行我的存储的过程。 但是，流分析似乎在我的SQL Server表中使用了批量插入，因此我的一些插入无法执行触发器，因为流分析的大容量插入似乎缺少FIRE_TRIGGERS选项。 有没有一种方法可以使用Azure Stream Analytics使用存储过程将数据导入SQL Server？
浏览 9提问于2020-07-25得票数 0
我有一个Azure SQL数据库 该公司有一个PABX系统，它有一个可以提供呼叫日志的API。 连接到API、提取呼叫日志并将其存储在Azure SQL DB的临时表中的最佳资源是什么？ 之后，我还需要调用Azure DB中的SQL来将数据处理到其最终位置。 我在考虑DataFactory，但不确定流分析是否可以工作。 我想从API获得近乎实时的数据馈送--可能每5/10秒一次。 ?
浏览 20提问于2021-02-02得票数 0
2回答
我有一个IOT集线器，它的设备可以将传感器数据推送到它，并存储在SQL数据库中。这似乎是相当容易通过一个流分析的工作。
然而，棘手的部分如下。我正在推送的数据不是规范化的，而且由于我使用的是SQL数据库，所以我希望将它构建在多个表中。对于来说，这似乎不是一个容易的任务。
这是我向IOT集线器推送的有效载荷的一个例子：
{
"timestamp" : "2019-01-10 12:00",
"section" : 1,
"measurements" :
{
"temperat
浏览 0提问于2019-01-13得票数 0
回答已采纳
我在O365中有一个Sharepoint列表，它用于通过从SQL数据库中捕获记录。
这个很管用。
我有第二个流，当一个记录(特别是一个字段)被修改时会触发它。这会将数据推回我的数据库。
这也很管用。
我遇到的问题是第二个流，它运行的次数和列的次数一样多。因此，如果我有10列，它运行10次，如果我有3次(测试了类似的过程，但在我的Dev环境中没有SQL更新)，它运行3次。
有没有人知道为什么会发生这种事，或者我怎样才能阻止它？
“自”字段中的公式如下：
sub(int(triggerOutputs()?'body/{VersionNumber}'),1)
浏览 4提问于2022-10-05得票数 0
我有一个设备发送数据帧到azure iot集线器，什么是“转换这些帧”并将其保存到SQL Db或Cosmos Db的最佳实践？
浏览 0提问于2018-10-31得票数 1
我有一个用于语言的解析器，如下所示：
[nodeType OPTIONAL STUFF]
有几个节点类型，例如"ask“和"set"，因此当前ask和set被定义为关键字。这会导致解析器的其他部分出现问题。
是否有一种方法来定义只接受包含特定文本的令牌的令牌解析器？
浏览 4提问于2016-05-04得票数 2
回答已采纳
2回答
我希望能为我的场景选择最合适的Azure服务--我刚刚开始使用Azure服务，我的知识非常有限。
我有来自多个来源和不同形状的数据，进入事件中心。我需要订阅事件集线器中的事件，并根据它们的格式处理它们，并最终将它们保存到SQL数据库中。所有组件--事件使用者，SQL数据库--都需要托管在云中。
我将如何在“面向蓝色的体系结构”中实现这一点？
在离云应用程序中，我会让竞争的消费者订阅事件中心。它们将是一些控制台应用程序或Windows服务，每个应用程序都将异步处理这些事件(由于事件处理是幂等的)，这进一步简化了。
理想情况下，上述用户的Azure等价物将自动伸缩，因此我不想使用托管控制台应用程序
浏览 2提问于2016-08-08得票数 1
回答已采纳
我正在使用SSIS将数据从Excel电子表格导入SQL数据库。我已经开始工作了。我使用数据流任务从Excel导入，然后移到OLE目标。
但是，我希望在移动它之前使用SQL查询添加一个列，其中包含当前日期(即导入到数据库的日期)。我唯一能执行SQL任务的地方是在“控制流”窗口中，我不知道该把它放在哪里。如果在数据流任务之前运行SQL，就不会有Excel文件可处理，但如果在数据流任务之后运行SQL，则该文件将已经导入数据库。
在流程的哪个点插入SQL任务？或者我应该使用两个数据流任务并在它们之间运行SQL任务？
浏览 0提问于2015-05-21得票数 0
回答已采纳
我有以下场景：
移动应用生成发送到Event Hub的事件，Event Hub是stream Analytics查询的输入流来源。从那里，它们通过一个连续的查询流，根据条件将流拆分为两个流，评估其他条件，并决定是否让事件继续流经管道(如果不是，则简单地丢弃)。你可以将我们正在做的事情归类为降噪/事件过滤。基本上，如果A刚刚发生，除非B&C发生或X时间过去，否则不要让A再次发生。在查询gauntlet的末尾，流被再次合并，并且“选定”事件被作为“选择”输出传播。
我的问题是，我需要能够将当前事件与前一个“选定”事件(而不仅仅是前一个输入事件)进行比较，因此在本质上，我需要将我的输入流连接
浏览 2提问于2017-06-09得票数 0
我有一个SQL Server表，其中的行被随机删除。我想检查是什么导致了这一点，因为我没有从应用程序方面看到任何问题。
我确实创建了一个after delete触发器，并且能够看到哪些行正在被删除，但这仍然无助于指出为什么要删除某些记录。
我想知道是否有可能记录/跟踪正在执行的SQL语句从我的表中删除行。
请注意，我正在使用SQL Server 2016速成版。
浏览 0提问于2016-08-26得票数 0
回答已采纳
2回答
我有每秒从传感器到Azure IoT集线器的JSON数据。数据是由15个变量组成的时间序列。我想使用c#应用程序实时处理此数据，该应用程序相当复杂，并将输出事件发送到其他服务(可以是存储或PowerBI)。您认为最好的架构方法是什么? 1.尝试使用c#代码处理流分析中的数据，我知道.Net支持天青流分析，但我认为还为时过早？有这种方法的经验吗? azure流分析是否支持复杂的c#算法? 2.将数据存储到azure数据湖并使用数据湖分析来处理数据？
非常感谢您的经验和建议。非常感谢
浏览 0提问于2017-07-05得票数 0
我正在使用SQL Advantage，需要知道SQL是什么来识别与表关联的触发器。我不能选择使用其他工具，所以优秀的老式SQL解决方案是理想的解决方案。
浏览 0提问于2008-11-25得票数 8
回答已采纳
我是Azure流作业的新手，我想使用Azure SQL DB中的引用数据加载到Power BI中以获得流数据。在设置SQL输入表时，我已经设置了存储帐户。我测试了输出表(Power BI)，它也很好，没有错误。 我测试了输入表和输出表的连接，两者都连接成功，并且我可以从输入预览中看到输入数据。 但是当我试图编写查询来测试它时，查询既不能检测输入表，也不能检测输出表。输出表图标也呈灰色显示。 错误消息:查询必须引用至少一个数据流输入。 你能帮我一下吗？ ? ? 谢谢你！！
浏览 21提问于2020-10-09得票数 0
我在实际检索和使用我发送到IoT集线器的数据时遇到了一些问题。当我在IoT中运行'az CLI集线器监视器-事件--集线器名称‘时，我可以看到我的事件，我还可以向我在IoT集线器中的设备发送消息。 然后，我尝试创建一个流，将消息转发到我的SQL数据库，但没有成功。关于如何检索这些数据，您有什么建议吗？
浏览 20提问于2021-02-03得票数 0
我们有一个具有无状态工作流的标准Logic。对于Azure Service总线，触发器是“消息在队列中可用时”，下一步是每个循环。这种组合似乎有一个缺陷，因为限制，并导致两个问题。
无状态触发器似乎只允许自动完成，因此在出现错误时，所有消息都会丢失.
无状态触发器似乎不允许配置批处理，因此任何大于100的批处理都会导致以下错误。
InvalidTemplate。无法处理操作“For_each”的模板语言表达式(行“{messageCount}”和列“{messageCount}”)：“操作超出了操作项限制的数量”for _each“：最大值'100‘和实际的’{mes
浏览 4提问于2021-10-12得票数 0
希望在事件流上进行实时指标计算，在Azure中什么是一个好的选择？Stream Analytics还是Storm？我对SQL或Java都很满意，所以我想知道其他的区别是什么。
浏览 0提问于2015-06-30得票数 7
1回答
Android中的声音分析/编辑
、、、、
我想知道在android中分析和编辑声音有多难。我的项目将是一种DJ应用程序。
我认为AudioTrack是最合适的库，对吧？几个android DJ应用程序如何工作来显示声音的频谱，应用效果，改变速度，混合等…他们是否使用了更强大的外部声音库？
对于性能问题，Java是否足够快(或者存在延迟风险)？
最后一个问题: Korg如何将其syth移植到Ipad上，Wormux如何移植到android上，AngryBird现在如何在Iphone和android上运行，等等。所有这些应用程序似乎都可以移植到任何平台上，而不需要重写...他们是怎么做的？是不是因为它们是用“原生代码”写的？我应该考虑这个
浏览 0提问于2010-09-27得票数 3
1回答
请有从azure门户连接到外部api的方法吗?如果可能的话，我如何创建一个流来调用api，获取数据并加载到azure sql server表中？
谢谢。
浏览 7提问于2022-07-11得票数 0
我想在Analytics中添加Mouseflow ID作为自定义维度。我有我的GTM正确集成，其他标签和触发器工作非常好。我在挣扎于以下几个方面：
我想我需要一个自定义变量，其中包含返回Mouseflow ID的javascript。
Google中的一个定制Javscript变量需要一个函数并返回，所以我不能直接在上面的网站上使用代码。我尝试过的两件事是：
$(window).load(function() {
return mouseflow.getSessionId;
});
和：
function() {
return mouseflow.getSessionId();
浏览 3提问于2016-04-26得票数 2
回答已采纳
我想使用SQL*Loader将数据加载到父子关系中的两个表中，使用in sequence。有可能吗？示例：
输入文件：
HDR|first batch
DAT|first element of first batch
DAT|second element of first batch
HDR|second batch
DAT|first element of second batch
必需的结果：
表HDR：
HDR_ID|title
1 |first batch
2 |second batch
表DAT (HDR_ID为外键)：
DAT_ID|HDR_ID|content
浏览 0提问于2016-07-18得票数 0
为什么我从来没有见过既有静态代码分析又有动态代码分析的分析工具，因此要同时检查它们？
附注: FxCop使用CIL解析和调用图分析来运行其检查。有人知道它是使用动态调用图分析还是静态调用图分析吗？
我承认，我对这些工具的了解有限，但我一直在做一些研究，似乎找不到两者结合在一起……如果你确实知道有一些工具可以同时做这两件事，请列出它们。
谢谢!
浏览 1提问于2011-05-03得票数 2
回答已采纳
我在libcurl周围实现了std::streambuf API的读取部分(即underflow()和xsgetn())，这样普通的istream就可以插入这样的streambuf，并从HTTP或istream服务器中检索内容。效果很好。
现在，我想实现API的写一半(即overflow()和xsputn())，用于将文件上传到FTP服务器，这样做如下：
ostream os( my_curl_streambuf );
curl_easy_setopt( my_curl_handle, CURLOPT_UPLOAD, 1L );
os << is->rdbuf(); // c
浏览 1提问于2013-12-28得票数 1
3回答
我正在开发一个Azure IOTHUB用例。
多个负载传感器连续(每隔1/2秒)向IOTHUB发送数据。(DeviceID，体重)。
带有用户数据的SQL表。
我想要建立一个系统，发送电子邮件通知一定重量的设备所有者。
，实现这一目标的正确方法是什么？
我看到过逻辑应用程序是一种选择，但是如何用多个用户帐户和设备来实现它。
浏览 0提问于2018-01-16得票数 0
我有一个Streaming设置，它消耗了一个Kafka主题，我需要使用一些使用的App，但是当我试图转换它时，我得到了以下内容
: org.apache.spark.sql.AnalysisException: Queries with streaming sources must be executed with writeStream.start();;
kafka
at org.apache.spark.sql.catalyst.analysis.UnsupportedOperationChecker$.org$apache$spark$sql$catalyst$anal
浏览 1提问于2019-03-05得票数 3
回答已采纳
在使用Trigger.Once结构化流和处理卡夫卡输入时
- then if running the `Trigger.Once` invocation
- and KAFKA is being written to as well simultaneously
- will the `Trigger.Once` invocation see those newer KAFKA records being written during current invocation?
- or will they not be seen until _next_
浏览 4提问于2022-02-25得票数 1
1回答
我在使用SQL为我的应用程序使用COSMOSDB，我需要从Azure COSMOSDB生成表格和可视化报告。我需要参考的标准方法或指南是什么?我猜直接将它与Power或SSRS这样的工具连接会导致某些问题。我需要对数据进行分析，因此生成reports.Creating数据仓库是生成此类报告的最佳方法，但是如何将数据从NoSQL COSMOSDB传输到Azure SQL。
有人能帮我澄清我的疑虑吗。
提前谢谢。
浏览 3提问于2020-02-14得票数 0
1回答
嗨，我试着在mysql查询中创建一个if语句，但是我不知道我哪里出错了。如果列值超过8小时，我试着从列值中减去8。以下是我迄今所做的
$sql="UPDATE timekeeping SET actualend = timestamp(NOW()), logoutdate = date(NOW()),
totalhours = ((SELECT sum(time_to_sec(timediff(actualend,actualstart))/3600) AS
'totalhours') - 1.50),
excesstime = (if (totalhours >
浏览 1提问于2014-05-07得票数 0
回答已采纳
我使用Github编写代码，使用GitLab CiCd编写管道，手动触发器工作得很好，但我正在尝试在新的更改推送到代码时自动触发管道。请提出一些想法。
浏览 3提问于2021-06-12得票数 1
我编辑了这个问题，因为下面的答案提到，当使用while和begin时，它应该在存储过程中。
所以现在我在一个存储过程中运行它，但是我仍然得到一个错误。
counter;
while counter < 2
begin
GOTO counter
SELECT var1 AS LOCATION,
ROUND(sum(CASE WHEN t2.tagid = var2 THEN t2.floatvalue ELSE 0 END), 2) AS MR
ROUND(sum(CASE WHEN t2.tagid = var3 THEN t2.floatvalue ELSE 0 END),
浏览 0提问于2013-11-21得票数 1
1回答
我使用Google Cloud Functions作为后台函数来监听GS存储桶上传入的CSV文件，然后触发Cloud SQL Import (MySQL)。
我能够成功地测试这个流，并看到加载到Cloud SQL中的CSV文件数据。
但是，我想从安全的角度验证这种方法，并探索是否有其他更好的选择。
我的理解是，由于没有为云函数(backgrounder )公开http端点，因此不应该存在安全漏洞。
我想从其他人那里验证这一点，并标记是否有任何我需要注意的具体问题。
浏览 0提问于2018-07-18得票数 0
我正在运行Oracle DB 9i。
我有一个具有各种约束的表，以确保数据的完整性。除了约束之外，我还在BEFORE INSERT和BEFORE UPDATE上设置了触发器，以确保必要的数据进入表中，在某些情况下允许应用程序层从其查询中省略信息，并在某些情况下强制将其存在。
我需要在BEFORE INSERT上执行的操作与BEFORE UPDATE不同。
我的问题是：
我可以有一个使用IF / THEN的通用触发器，还是应该创建单独的触发器？
例如：
-- Scenario 1
CREATE OR REPLACE TRIGGER my_trg
BEFORE
浏览 0提问于2014-07-28得票数 0
回答已采纳
是否有可能为某些用户和/或某些应用程序创建某种“系统”触发器，从而启用/禁用对整个数据库的更新、插入、删除命令的执行？
我知道我可以执行一个登录触发器，它将不允许用户登录和/或从应用程序登录到SQL服务器。我知道它可能会通过在每个表上创建触发器来工作，但这是不切实际的。毕竟，SSMS活动监视器会准确地看到哪个用户正在运行哪个命令，哪个主机。
例子: Application1，application2和user1，user2
Server 2014：
User1 from application1可以运行所有命令(选择、更新、插入、删除.)
User1 from application2不允许运
浏览 8提问于2021-11-13得票数 0
是否有任何方法通过提交消息值触发特定的Github操作工作流？例如，如果我使用提交消息"smoke_test"，那么只有(一个特定的工作流)冒烟测试工作流应该从一组工作流中触发。帮帮忙，谢谢！
浏览 2提问于2021-12-16得票数 6
我想在dbForge sql窗口上运行SQL语句，但得到错误：
if (ifnull(null,'s') = 's') then
select 's';
end if;
错误：
1 You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'if (ifnull(null,'s') = 's') th
浏览 0提问于2012-06-14得票数 0
回答已采纳
我正在做一些IoT集成，我想知道在Azure中哪里可以解析我的IoT数据(JSON数据)。 我之前的工作流程是这样的:传感器推送数据sql集线器->流分析作业-> ->数据库。流分析工作运行良好，但我听说它不是在Azure中解析数据的“正确”方式。那么，什么是正确和最好的方法来做到这一点。我需要将它保存到SQL数据库中。
浏览 19提问于2019-05-07得票数 0
1回答
当使用下面的代码从When服务中检索对象时，我发现合并这几行代码后，速度减慢了大约.5s。
$getChildren = $OKMDocument->getChildren(array('token' => $token, 'path' => $path));
$fileArray = $getChildren->return;
至
$fileArray = $OKMDocument->getChildren(array('token'=> $token, 'path' => $path)
浏览 1提问于2013-01-30得票数 1
回答已采纳
我们目前有一个使用SQL Server 2014作为数据库的旧式桌面应用程序。我们想在软件之外添加一些我们没有源代码的额外功能。 当桌面软件中的某个任务完成时，我们如何监控数据库中的不同表中插入、更新或删除了哪些数据？这将允许我们以桌面应用程序当前正在做的相同方式向数据库添加数据。 我们已经尝试过SQL事件探查器，但似乎无法获取信息。 有没有办法从一个数据库中获取两个时间点之间的差异？
浏览 15提问于2019-10-10得票数 2
回答已采纳
2回答
好日子
我有一个应用程序，它通过Azure EventHub通过Azure SQL数据库中的Azure流分析传递数据。此数据来自Cost Recovery Software每隔几分钟写入的一个文件，其中包含最新的完整帐户列表。
我希望确保当文件中的所有数据都通过此过程时，会发生某种形式的合并，仅更新现有帐户并插入不存在的帐户。确保不会创建重复的帐户。
我不确定Stream Analytics是否是将数据从EventHub提供给SQL的最佳选择。
流程示例：
浏览 1提问于2019-03-22得票数 0
4回答
我需要创建一个SQL Server数据库，它将通过某种复制机制从另一个数据库接收更新。我需要编写insert、update和delete触发器，这些触发器将在此复制发生时执行。
我有触发器的经验，但没有复制的经验。
我应该使用事务性复制还是合并复制，或者这有什么关系？
设计为在执行简单SQL insert语句时运行的触发器是否也会在发生复制时运行？
浏览 0提问于2009-02-12得票数 4
回答已采纳
2回答
我正在使用流分析来检索放置在IoTHub上的JSON消息。我需要能够检索原始JSON字符串并将其存储在SQL Server表中。我似乎找不到一种方法来做这件事。有可能吗？
浏览 40提问于2018-03-04得票数 0
回答已采纳
3回答
我正在开发库存管理系统.I想要在插入到一个表之后更新两个表，所以我已经使用SQL触发器完成了它，但是这个触发器不是来自C# (我的应用程序的前端)，我不知道如何从C#.Can那里触发一个触发器，因为我必须在周日提交这个项目。这是我的SQL触发器。
CREATE TRIGGER tbl_Sales_ForInsert
ON SALES
FOR INSERT
AS
BEGIN
DECLARE @ITEMMODEL varchar(100)
SELECT @ITEMMODEL = @ITEMMODEL FROM inserted
update SALES set
浏览 7提问于2014-02-18得票数 0
回答已采纳
我目前正在物联网上工作，在我目前的项目中，我实现了将温度值发送到IoT集线器(使用树莓PI2和BMP280传感器)的逻辑，在蓝色部分，我创建了用于接收来自IoT集线器的消息的流分析作业，并根据我的查询过滤这些值，如如果温度值超过30度，并将那些过滤值发布到事件集线器是流分析作业的输出之一。
我在流分析作业中编写的查询。
SELECT
System.timestamp AS Time,
DeviceId,
RoomTemp,
RoomPressure,
RoomAlt
INTO
eventhub
FROM
bmpsensordata
WHERE RoomTemp>
浏览 2提问于2016-05-05得票数 2
我有多个AWS kinesis数据流/firehose和CSV格式的结构化数据。我需要使用运动数据分析对这些数据执行分析。但是如何将多个流合并为一个流呢？因为Kinesis数据分析仅从一个流中获取数据。数据流可以存在于不同的地域。
问题:如何将Kinesis数据流合并为一个用于Kinesis数据分析的数据流？
浏览 3提问于2020-08-25得票数 0
我想在Prometheus中监视当前运行的cadence工作流的数量。
我检查了由不同的cadence服务(如cadence_history、cadence_worker、cadence_frontend等)导出的度量，我可以找到的唯一与工作流相关的度量是：
activity_end_to_end_latency histogram (workflowType是其中一个标签)
workflow_success counter / workflow_terminate counter / workflow_failed counter
因此，似乎有一些指标可以分析已经完成的工作流
浏览 11提问于2022-06-15得票数 1
我有一个运行数千个测试用例的java项目。我使用的是带有testng的maven-surefire-plugin。当这些测试在远程机器上运行时，我想对它们进行分析。它基本上是一个典型的maven构建过程，然后运行测试用例。我尝试使用JProfiler的远程附加功能，但这会导致我的测试用例继续执行。是否有一种方法可以在服务器执行和分析时在服务器上创建快照。像一些插件/依赖，我可以添加到我的项目。我可以看到使用JProfiler进行堆转储的选项，但是找不到快照的文档。
尝试使用远程附加，但是它花费的时间太长，测试用例一直在执行，而且永远不会完成。
浏览 11提问于2022-03-24得票数 1
回答已采纳
我正在跟踪，但我试图稍微偏离一下，在VPN上使用一个基于前提的SQL server ( web应用程序已经使用了)。
在添加输出时，这是失败的，因为：
是IP地址不受支持，还是比IP地址更基本？
浏览 0提问于2018-11-26得票数 1
回答已采纳
对于每个连接或每次执行，nocount是用SQL表示的吗？
考虑以下几点
-- Proc to return data.
-- nocount is set to on (no row count returned)
create procedure procOne as
set nocount on
select * from myTable
如果我有一个调用procOne的应用程序，然后执行一个SQL调用，比如: DELETE from myTable where foo = bar
delete语句会返回删除的行数吗？我说可以。
该过程应仅在其执行过程中设置nocount值。
浏览 0提问于2009-06-22得票数 1
2回答
SQL Server通知
、、、
我正在构建一个从SQL Server中提取数据的应用程序，服务器的版本从2005到2012可能会有所不同，但最重要的是2008和2012。
如果我想监听对数据库中某些表和行的更改，并发送或获取这些更改并在我的C#应用程序中使用它们，那么最好的方法是什么？
我不需要更新数据库中的任何数据，这是另一个已经存在的应用程序的工作。
我只想倾听变化，或轮询变化，或任何类似的东西。
根据您的经验，Service Broker是最好的吗？查询通知？MSMQ？SqlDependency？更改数据跟踪？
提前感谢！
浏览 0提问于2012-08-30得票数 3
我正在调查、Google、Dataflow、和Apache ，以决定哪种解决方案更适合我们的大数据分析业务需求。
我发现在spark平台中有Spark SQL和MLlib来进行结构化数据查询和机器学习。
我想知道谷歌数据流平台中是否有相应的解决方案？
浏览 2提问于2015-11-04得票数 32
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
