我写了一篇Flink CEP文章，用Relaxed Contiguity (followedBy)检查状态模式(由id键入)。这个想法是，如果特定的状态在指定的时间内没有在第一个状态之后到达，就发出警报。 这是可行的，但是，如果有更多的消息发送到此数据流，则永远不会触发警报。但只有当具有某种随机状态的消息到达时，才会触发这段<e
浏览 31提问于2020-01-17得票数 0
这次同步有点不稳定，所以我想检测同步何时停止并发出警报。由于其他设备未响应，Synchronization requestSynchronization successfulSynchronization失败
所以，我想做的是：收到请求，一段时间后什么也没有收到，我想在收到请求时发出超时告警，并且在超时时间内，成功事件到达，<em
浏览 50提问于2018-06-08得票数 0
我已经在js代码中设置了ApplicationInsights，每当我向它发送数据时，都会正确地跟踪它，并且我可以在门户中看到它。现在，我想设置一个电子邮件通知时，错误或自定义的指标发生。从下面的图片中可以看到，我已经设置了3个警报。第一个2 (ServerErrors和BrowserErrors)工作正常，我收到电子邮件通知。在Metrics中，我看到了度量，但我无法调查度量细节，因为详细信息选项卡在门户中“正在构建”。我不知道我做错了什么。
此外，有时在任何警报的左侧都会出现
浏览 1提问于2015-10-20得票数 0
回答已采纳
我们正在考虑flink作为一个用例，但不确定flink是否适合它。这是我的用例。当一个事件e1到达时，我们需要处理它并发出一个结果。源和接收器与本讨论无关，但您可以将消息队列服务视为源和接收器。事件的整个处理是独立于其他事件的。因此，在处理事件e1时，我们不需要e2或任何其他事件。作为处理的一部分，我们需要执行step1、step2、step3、step4，如下图所示。因此，我需要在该元素的处理完成后立即发出
浏览 19提问于2019-06-27得票数 1
回答已采纳
4回答
我们有一个客户端，它需要从服务器获取交互式消息，从分布在世界各地的客户端获取交互消息，这些客户端分布在各种防火墙后面，所有端口都已关闭。客户端向.NET处理程序发出GET请求；处理程序在一段时间内保持请求打开，以查找消息。如果有任何消息到达，则会立即将其发送到客户端；如果没有，则在超时后关闭连接，并显示"no-data“响应。首先，实际
浏览 2提问于2008-09-23得票数 3
回答已采纳
我们使用Mandrill发送电子邮件，我们想知道关于无法传递的消息的SMTP响应。例如，当收件人的邮箱已满时，就会出现552。如果是这样，如果邮件不能立即送达，会发生什么？是否存在超时，使SMTP服务器即使在电子邮件未送达时也会做出响应？
浏览 1提问于2018-07-19得票数 0
我正在使用c++和winsock lib在windows中开发客户端服务器应用程序，它工作得很好，但如果它在网络上，一旦服务器侦听开始，如果我移除了网线，那么服务器在任何线程中都不会显示任何错误，因此服务器套接字知道网线已拔出如果有人知道，请帮帮我。
浏览 3提问于2011-12-14得票数 1
回答已采纳
2回答
我有一个关键任务的实时数据应用程序，它使用客户端和服务器之间的TCP连接。在某些情况下，连接周期性地死亡(SocketException)。没问题-重新联系，继续前进。，我是否可以从TcpClient、套接字或其他任何指标中提取一些指标来告诉我连接的健康状况呢？可能是平均的攻击时间、重试次数等等？首先，如果服务器隐藏在NAT后面，我可能会敲路由器。
浏览 3提问于2008-10-15得票数 3
3回答
在我的x++代码中，我有以下内容 try startLengthyOperation(); }
}
我正在命中最后的捕获(之前，我没有收到任何关于异常的消息
浏览 1提问于2011-01-15得票数 5
回答已采纳
但是，如果零条记录是在24小时前发布的，而不是仅在3小时前发布的，那么您的应用程序在到达3小时前发布的记录之前，需要对前21小时进行迭代轮询吗？(注意:我们不记得/重复使用步骤3中的切分迭代器)
对于上面的步骤5，在流上发布"Item=A“消息已经超过24小时了，而"Item=B”已经发布一分钟了。在手动处理AFTER_SEQUENCE_NUMBER迭代器类型并使用几天前我的使用者日志中的一些序列号之后，我能够<e
浏览 3提问于2015-09-30得票数 13
回答已采纳
3回答
我有一个数据表，它用一个不断增加的索引(n++)发送数据。其中一些数据有可能无法正常发送、丢失或需要重新传送。假设我有一个由我的应用程序监视的安全日志文件。对于一个坏人来说，有可能抑制或阻止少数条目的传播。还假定这些数据可能会被发送到日志记录器中。。我应该如何实现(或存在什么引用实现)，以便跟踪按顺序接收到的数据，并可能在序列中包含丢失的数据？
(也感谢你协助标注这一问题)
浏览 4提问于2012-05-12得票数 2
回答已采纳
基于ERP中的某些触发器(例如价目表更改)，我们将把所有受影响的客户编号放入一个队列中，而一个侦听该队列的Azure函数将重新计算该特定客户的价格。
示例:对价目表进行更改后，用户单击保存。如果计算需要2秒，并且我们可以并行进行10次计算，则3000*2/10=600秒后将完成最后一个客户的价格。当客户编号在队列中等待时，用户执行另一项更改并单击Save。如果队列中已经存在具有相同内容的另一条消息，是否有其他方法可以避免将<
浏览 1提问于2020-04-23得票数 0
1回答
我们有一个这样的云设置：我们在一些页面上支持如果请求通过HTTP访问应用程序(Apache)，则当特定页面需要SSL时，它会重定向到HTTPS。当对安全资源的请求到达我们的应用程序时，如果应用程序发送Cache-Control: public，squid会正确地缓存该内容。问题是，如
浏览 1提问于2010-11-05得票数 0
回答已采纳
我有一个连续的实时数据流。它必须立即使用或丢弃，因此我使用UDP进行传输，而不使用ACK或重传(连接不可靠)。AES密钥是在已知的有线安全信道上预先共享的。
浏览 0提问于2019-12-27得票数 1
回答已采纳
1回答
如果这些线程积累起来，最终可能会出现问题。下面是我检测断开连接的尝试，但是这会导致服务器结束时没有消息
浏览 3提问于2014-01-08得票数 0
回答已采纳
我了解到，await是一种非常有效的方法，可以在当前函数等待长期运行的任务时执行事件循环中的其他代码。它在web应用程序中非常有用，因为一个API调用不应该阻止其他所有的应用程序。但是，如果我有一个简单的Lambda (调用Api并返回响应)，那么当Javascript事件循环没有执行任何操作时，Lambda函数会做什么？
首先，每个Lambda一次只能处理一个请求。因此，在处理程序被阻塞时，另一个处理程序可能会突然出现并执行。其次，在完成await之前，Lambda函
浏览 6提问于2022-07-21得票数 0
回答已采纳
假设我有一个整天负载很大的队列。队列中的每一条消息都需要几秒钟的时间来处理。
如果我有4台机器都安装了外部激活器(全部配置为相同的队列/服务)，这会有效吗？如果它确实工作了，它会负载平衡(将工作均匀地分布在工人机器上)吗？
浏览 1提问于2013-09-03得票数 0
回答已采纳
1回答
该图考虑了一般的两种情况:书在缓存中，或者这本书不在缓存中。但是，该图没有考虑从数据库中检索图书和其他“获取相同图书”请求到达时的短暂情况。在这种情况下，我想将重复的请求暂时排队，直到检索到图书为止。下一步，一旦图书已经到达，排队的请求将用结果回复，该结果将保留在缓存中，以便快速检索未来的请求。
因此，我的问题要求提供实现此要求的方法。所以我想知道是否有人知道这个模式，或者Redis本身是否以某种方式实现了它(我在咨询中没有发现它，但我怀疑使用Redis锁是可能的)
浏览 1提问于2019-11-01得票数 1
我发现Apache、Apache、Apache和TIBCO StreamBase是一些强大的流处理框架.但我不知道哪一个有最好的性能和能力。但是Apache和TIBCO StreamBase是专门为流处理而建的.这些框架之间有什么相当大的优势吗？
谢谢
浏览 0提问于2015-01-29得票数 3
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
