多输入或单输入接收器 [英] Multiple or Single Input Sink
问题描述
您好，
我当前的应用程序从多个（100 +）TCP流中获取突发数据，放入单个并发列表，然后解码和分析数据包内容 提供各种实时仪表板KPI。我还聚合KPI并插入到SQL
服务器中进行历史分析。
我想调查更改解决方案以使用StreamInsight，希望通过管理 来提高效率。传入数据和灵活的仪表板报告，我的问题是如何执行此操作：
应该为每个TCP插槽创建一个输入接收器或继续管理要加入的列表所有TCP数据并提供单个接收器？
除了在所有TCP套接字上平均和报告KPI以提供性能的网络视图外，我还希望能够深入研究和查询各个TCP流，实现这一目标的好方法是什么？
感谢您提供的任何指示！
您的数据是什么样的？这一点很重要，因此您可以创建适当的有效负载类以在StreamInsight中使用。它至少会包含某种TCP流标识符，用于标识哪个事件属于哪个TCP流。
1。所有这些TCP流是否都连接到同一个套接字？如果您在StreamInsight 2.1中使用基于Rx的方法，则输入是源，而接收器是输出。您需要为每个要接受
接受数据的插槽创建输入源。
2。您可以创建一个WCF接收器，允许您的仪表板订阅他们想要显示的数据。因此，默认情况下，您可以订阅聚合数据。然后，如果您想深入查看特定TCP流上的细节，您可以
订阅您的WCF接收器将处理过滤相关事件的那些事件。
Hello,
My current application takes bursty data from multiple (100+) TCP streams, puts into a single concurrent list and then decodes and analyzes packet contents to provide various realtime dashboard KPIs. I also aggregate KPIs and insert into SQL server for historical analysis.
I would like to investigate changing the solution to use StreamInsight in the hope to make more efficient with managing the incoming data and flexible with dashboard reporting, my question is how to go about doing this:
Should I create a input sink for each TCP socket or continue to manage a list to join all the TCP data and feed a single sink ?
As well as averaging and reporting KPIs across all the TCP sockets to provide a Network view of performance, I want the ability to drill-down and query on individual TCP streams, what would be a good approach to achieve this ?
Thanks for any pointers you can provide !
What does your data look like? This is important to know so you can create a proper payload class for use in StreamInsight. At a minimum, it will contain some kind of TCP stream identifier that identifies which event belongs to which TCP stream.
1. Are all these TCP streams connecting to the same socket? If you are using the Rx-based approach in StreamInsight 2.1, inputs are sources while sinks are outputs. You would need to create an input source for each socket you want to accept data on.
2. You could create a WCF sink that would allow your dashboard(s) to subscribe to the data they want to display. So by default, you can subscribe to the aggregate data. Then if you want to drill-down to see the specifics on a specific TCP stream you can subscribe to those events which your WCF sink will handle filtering out the relevant events.
这篇关于多输入或单输入接收器的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！
