扩展 Kuiper允许用户自定义不同类型的扩展。 源扩展用于扩展不同的流源,例如使用来自其他消息服务器的数据。 Kuiper对 MQTT消息服务器的内置源提供支持。 Sink / Action扩展用于将发布/推送数据扩展到不同的目标,例如数据库,其他消息系统,Web界面或文件系统。 Kuiper中提供内置动作支持,请参阅 MQTT & 日志文件.。 函数扩展允许用户扩展SQL中使用的不同函数。 Kuiper支持内置函数,请参见 functions。 请阅读以下内容,了解如何实现不同的扩展。 源扩展 Sink/Action 扩展 函数扩展