开发人员指南 (StreamInsight)

Microsoft StreamInsight 平台包括一个功能稳定的对象模型，该模型包含的很多功能可以使 StreamInsight 应用程序编程更轻松、更灵活和更有效。本节介绍了您可以用来创建 StreamInsight 应用程序的开发模型和指南，并给出示例。

本节内容

• 编程时的注意事项
  介绍 StreamInsight 编程中的一些要求

• StreamInsight 端到端示例
  介绍在创建 StreamInsight 应用程序时涉及的不同组件和步骤并且包括应用程序的一个端到端示例。

• 创建事件类型
  提供了关于创建事件类型的指导原则。事件类型定义事件源发布的事件或事件接收器使用的事件。

• 创建输入和输出适配器
  提供创建输入和输出适配器所需的信息。适配器是将事件传递到 StreamInsight 服务器或从中传出的软件转换器。

• 使用可观察和可枚举的事件源和事件接收器 (StreamInsight)
  介绍 StreamInsight 中对实现 IObservable 和 IEnumerable 接口的事件源和事件接收器的支持。这些接口是 .NET Framework 中主导的通用约定，用来在应用程序各组件之间请求 (IEnumerable) 和推送 (IObservable) 数据。

• 启动和停止查询
  介绍如何启动和停止 StreamInsight 服务器中的查询。

• 在 LINQ 中编写查询模板
  说明如何编写 LINQ 查询以便对已传递到 StreamInsight 服务器中的数据执行各种计算操作。 

• 将应用程序时间提前
  介绍如何使用当前时间增量 (CTI) 来提交事件序列以及向查询输出释放计算结果。CTI 是一种特殊的标点事件，是 StreamInsight 临时模型的中心组件。

• 在运行时撰写查询
  介绍如何通过在运行时撰写查询来提高查询灵活性、可重用性和易于维护性。

• 发布到和连接到 StreamInsight 服务器
  介绍如何发布到或连接到 StreamInsight 服务器。

• 生成弹性 StreamInsight 应用程序
  介绍如何实现在系统失败后可以恢复查询状态的 StreamInsight 应用程序。

• 安全和保护 (StreamInsight)
  介绍 Microsoft StreamInsight 的重要安全信息。

• 使用 StreamInsight 事件流调试器
  介绍 StreamInsight 事件流调试器。借助该调试器，您可以通过 StreamInsight 查询检查、调试和推断事件流。

API 参考

作为平台，StreamInsight 以在主机上安装的一组 DLL 的形式出现。下表列出了已安装 DLL 的子集，为了开发 StreamInsight 应用程序需要将它们作为 Visual Studio 项目引用。 

DLL	包括的命名空间和功能
Microsoft.ComplexEventProcessing	Microsoft.ComplexEventProcessing 应用程序 SDK。 Microsoft.ComplexEventProcessing.Linq StreamInsight 查询模板语言。 Microsoft.ComplexEventProcessing.Extensibility 用于用户定义聚合和运算符的 API。
Microsoft.ComplexEventProcessing.Adapters	Microsoft.ComplexEventProcessing.Adapters 适配器 API。
Microsoft.ComplexEventProcessing.ManagementService	Microsoft.ComplexEventProcessing.ManagementService 用于公开 Web 服务方法的 API。

请参阅

概念

规划和体系结构 (StreamInsight)

StreamInsight 服务器概念