Dónde colocar los archivos de adaptador personalizados

Si tienes tu parte mqtt_input.cnxml archivo en el lugar correcto, podrá ver su adaptador de entrada personalizado en el cajón Adaptadores de entrada en la paleta.

Cree un nuevo proyecto de transmisión con el complemento Streaming Analytics. Utilizar el ccl código proporcionado a continuación para el proyecto que se muestra en la imagen.

CREATE INPUT WINDOW InputWindow1 SCHEMA ( Message string )
PRIMARY KEY ( Message ) KEEP ALL ROWS ;

ATTACH INPUT ADAPTER MQTT_Input_Adapter1
TYPE mqtt_input TO InputWindow1
PROPERTIES  mosquittoServerAddress = 'tcp://<your-ip-address>:1883' ,
topic = 'test' ;

Haga clic en el Hecho botón a continuación cuando haya completado este tutorial.