{"type":"doc","content":[{"type":"paragraph","content":[{"text":"Compute plugins are used similarly to input plugins and output plugins. First, you need to specify your plugin details in appsettings.xml. Than you use the EventDefinition.xml to define the data routing. For more details see the following page.","type":"text"}]},{"type":"paragraph","content":[{"text":"Edge Configuration","type":"text","marks":[{"type":"link","attrs":{"href":"/wiki/spaces/WD/pages/4124672012"}}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Loading your compute plugin","type":"text"}]},{"type":"paragraph","content":[{"text":"In your ","type":"text"},{"text":"appsettings.xml","type":"text","marks":[{"type":"code"}]},{"text":" configuration file, add a section ","type":"text"},{"text":"ComputePlugins","type":"text","marks":[{"type":"code"}]},{"text":" which might contain the loading configuration for one or several compute plugins. Refer to the following example ","type":"text"},{"text":"appsettings.xml","type":"text","marks":[{"type":"code"}]},{"text":".","type":"text"}]},{"type":"codeBlock","content":[{"text":"\n\n \n \n $(RuntimePath)Plugins/Egress/MqttNet/MqttNetPlugin.dll\n Senseforce.Agent.Extensibility.Egress.Plugins.MqttNet.MqttHandlerTpl\n $(LunaAppDataPath)configurations/OutputPlugins/MqttNet/MqttSettings.xml\n \n \n\n \n \n $(RuntimePath)Plugins/Ingress/HelloWorld/HelloWorld.dll\n Senseforce.Agent.Extensibility.Ingress.Plugins.HelloWorld.HelloWorldHandler\n $(LunaAppDataPath)configurations/InputPlugins/HelloWorld/HelloWorldSettings.xml\n \n \n\n \n \n $(RuntimePath)Plugins/[PathToYourPluginDll]\\HelloWorldCompute.dll\n Senseforce.Agent.Extensibility.Compute.Plugins.HelloWorld.HelloWorldComputeHandler\n $(LunaAppDataPath)configurations/ComputePlugins/HelloWorldCompute/DemoSettings.xml\n \n \n\n \n Live\n\n \n \n $(LunaAppDataPath)configurations\n EventDefinition.xml\n \n\n \n \n $(LunaAppDataPath)Logs\n agent.log\n \n Information\n \n","type":"text"}]},{"type":"paragraph","content":[{"text":"Please refer to ","type":"text"},{"text":"lines 20 to 26","type":"text","marks":[{"type":"strong"}]},{"text":" for how to load a compute plugin. The other sections are described in detail here: ","type":"text"},{"text":"https://manual.senseforce.io/manual/senseforce-edge/edge-configuration/which-plugins-to-load-appsettings.xml","type":"text","marks":[{"type":"link","attrs":{"href":"https://manual.senseforce.io/manual/senseforce-edge/edge-configuration/which-plugins-to-load-appsettings.xml"}}]},{"text":". As a summary, we see that we are loading three plugins. One output plugin, one input plugin and one compute plugin.","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Output Plugin","type":"text","marks":[{"type":"strong"}]},{"text":": Mqtt-Plugin with the name “Mqtt_senseforce” (see line 5 to 8)","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Input Plugin","type":"text","marks":[{"type":"strong"}]},{"text":": HelloWorld-Plugin with the name “HelloWorld” (see line 13 to 17)","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Compute Plugin","type":"text","marks":[{"type":"strong"}]},{"text":": HelloWorldCompute-Plugin with the name “Compute_demo” (see line 21 to 25)","type":"text"}]}]}]},{"type":"paragraph","content":[{"text":"The compute plugin configurations are:","type":"text"}]},{"type":"panel","attrs":{"panelType":"info"},"content":[{"type":"paragraph","content":[{"text":"The plugin attribute \"","type":"text"},{"text":"name","type":"text","marks":[{"type":"strong"}]},{"text":"\" is reserved for future use and does not provide any further service.","type":"text"}]}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"FilePath","type":"text","marks":[{"type":"strong"}]},{"text":" (Line 21): This setting needs to point to your main plugin binary. You might use the Senseforce Edge relative path specifiers as described in the section \"Path helpers\" below or you might use an absolute file path.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"TypeName ","type":"text","marks":[{"type":"strong"}]},{"text":"(Line 22): Fully qualified class-name of the plugins entrypoint. It consists of ","type":"text"},{"text":"[namespace].[classname].","type":"text","marks":[{"type":"code"}]},{"text":" Eg. if your plugin C# class is ","type":"text"},{"text":"HelloWorldComputeHandler","type":"text","marks":[{"type":"code"}]},{"text":" in the namespace ","type":"text"},{"text":"Senseforce.Agent.Extensibility.Compute.Plugins.HelloWorld","type":"text","marks":[{"type":"code"}]},{"text":", your typename resolves to ","type":"text"},{"text":"Senseforce.Agent.Extensibility.Compute.Plugins.HelloWorld.HelloWorldComputeHandler","type":"text","marks":[{"type":"code"}]},{"text":".","type":"text"}]}]}]},{"type":"panel","attrs":{"panelType":"success"},"content":[{"type":"paragraph","content":[{"text":"TypeName","type":"text","marks":[{"type":"code"}]},{"text":" can be any combination of your","type":"text"},{"text":"[namespace].[classname]","type":"text","marks":[{"type":"code"}]},{"text":". It's not necessary, that your ","type":"text"},{"text":"TypeName ","type":"text","marks":[{"type":"code"}]},{"text":"s in the ","type":"text"},{"text":"Senseforce.Agent.","type":"text","marks":[{"type":"code"}]},{"text":" - Namespace","type":"text"}]}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"ConfigurationFile","type":"text","marks":[{"type":"strong"}]},{"text":" (Line 23): Each plugin might (optionally) have a configuration file. You might want to refer to this configuration file in the ","type":"text"},{"text":"appsettings.xml","type":"text","marks":[{"type":"code"}]},{"text":" as this path is provided as parameter of the compute plugins constructor - allowing to load the configuration file during plugin setup. You might use the Senseforce Edge relative path specifiers as described in the section \"Path helpers\" below or you might use an absolute file path. This setting is optional and might be empty.","type":"text"}]}]}]},{"type":"heading","attrs":{"level":4},"content":[{"text":"Summary","type":"text"}]},{"type":"paragraph","content":[{"text":"Execute the following steps to load a compute plugin with your Senseforce Edge:","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Add ","type":"text"},{"text":"ComputePlugins","type":"text","marks":[{"type":"code"}]},{"text":" - section to your ","type":"text"},{"text":"appsettings.xml","type":"text","marks":[{"type":"code"}]},{"text":" (see line 20 to 26).","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Add one or several ","type":"text"},{"text":"ComputePlugin","type":"text","marks":[{"type":"code"}]},{"text":" - sections (see line 21 to 25). Each ","type":"text"},{"text":"ComputePlugin","type":"text","marks":[{"type":"code"}]},{"text":" needs to have:","type":"text"}]},{"type":"orderedList","attrs":{"order":1},"content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"FilePath","type":"text","marks":[{"type":"code"}]},{"text":" (Path to where to find the plugin)","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"TypeName","type":"text","marks":[{"type":"code"}]},{"text":" (Fully qualified class-name of your plugin implementation)","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Optional: ","type":"text"},{"text":"ConfigurationFile","type":"text","marks":[{"type":"code"}]},{"text":" (File path to the plugin’s own configuration file. This path will be provided as parameter in the plugin constructor).","type":"text"}]}]}]}]}]},{"type":"heading","attrs":{"level":4},"content":[{"text":"Path helpers","type":"text"}]},{"type":"paragraph","content":[{"text":"For the ","type":"text"},{"text":"FileName","type":"text","marks":[{"type":"code"}]},{"text":" as well as the ","type":"text"},{"text":"ConfigurationFile","type":"text","marks":[{"type":"code"}]},{"text":" you need to set either an absolute path, or use the Senseforce edge relative path modifiers. Two modifiers are available:","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"$(RuntimePath): ","type":"text","marks":[{"type":"strong"}]},{"text":"This path points to the location where your main Edge binaries are installed. For example, if your Edge is installed at \"","type":"text"},{"text":"C:/ProgramFiles/Edge/Luna.exe","type":"text","marks":[{"type":"strong"}]},{"text":"\", and you set your FileName to ","type":"text"},{"text":"$(RuntimePath)Plugins/MyDll.dll","type":"text","marks":[{"type":"strong"}]},{"text":", your path will resolve to ","type":"text"},{"text":"C:/ProgramFiles/Edge/Plugins/MyDll.dll","type":"text","marks":[{"type":"strong"}]},{"text":".","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"$(LunaAppDataPath): ","type":"text","marks":[{"type":"strong"}]},{"text":"This path points to the location where your edge configurations are located. If you run your Edge as console application, the configuration location is ","type":"text"},{"text":"[yourEdgeInstallationFolder]/configs","type":"text","marks":[{"type":"strong"}]},{"text":". As an example, if you set your ConfigurationFile setting to ","type":"text"},{"text":"$(LunaAppDataPath)configurations/MyPlugin/config.xml","type":"text","marks":[{"type":"strong"}]},{"text":", your path will resolve to ","type":"text"},{"text":"[yourEdgeInstallationFolder]/configs/configurations/MyPlugin/config.xml. ","type":"text","marks":[{"type":"strong"}]},{"text":"If you run your Edge as windows service, the default location of your configurations is \"","type":"text"},{"text":"C:/ProgramDate/Senseforce/Luna Data/[YourServiceName_ID]/configs","type":"text","marks":[{"type":"strong"}]},{"text":"\". Now our example from before resolves to ","type":"text"},{"text":"C:/ProgramDate/Senseforce/Luna Data/[YourServiceName_ID]/configs/configurations/MyPlugin/config.xml.","type":"text","marks":[{"type":"strong"}]}]}]}]},{"type":"panel","attrs":{"panelType":"info"},"content":[{"type":"paragraph","content":[{"text":"Do not add a slash or backslash (\"","type":"text"},{"text":"/","type":"text","marks":[{"type":"strong"}]},{"text":"\", \"","type":"text"},{"text":"\\","type":"text","marks":[{"type":"strong"}]},{"text":"\") behind your relative path modifier.","type":"text"}]}]},{"type":"panel","attrs":{"panelType":"warning"},"content":[{"type":"paragraph","content":[{"text":"Ordinary relative paths without the relative path modifiers are not supported.","type":"text"}]}]},{"type":"heading","attrs":{"level":2},"content":[{"text":"Routing data to and from compute plugins","type":"text"}]},{"type":"paragraph","content":[{"text":"For a general understanding about the Senseforce data routing engine visit the following manual page.","type":"text"}]},{"type":"paragraph","content":[{"text":"Edge Data Routing (EventDefinition.xml)","type":"text","marks":[{"type":"link","attrs":{"href":"/wiki/spaces/WD/pages/4125130772"}}]}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"The Senseforce data routing architecture","type":"text"}]},{"type":"paragraph","content":[{"text":"To deepen the understanding of Senseforce Edge data routing, the high-level architecture of the Senseforce Edge is described here.","type":"text"}]},{"type":"paragraph","content":[{"text":"The main element of the Edge data routing is a central stream processor and multiplexer. The output messages of each input plugin are routed to the stream processor. Furthermore, output plugins can subscribe to one or several messages of the stream processor.","type":"text"}]},{"type":"paragraph","content":[{"text":"With the compute plugins now being available, compute plugins can also subscribe to one or several messages of the stream processor. Furthermore, all results of compute plugins are redirected back to the stream processor, allowing either other compute plugins or output plugins to consume these messages via the stream processor infrastructure.","type":"text"}]},{"type":"heading","attrs":{"level":4},"content":[{"text":"How to subscribe for messages?","type":"text"}]},{"type":"paragraph","content":[{"text":"Each message coming to the Stream processor needs to have an ","type":"text"},{"text":"IngressKey","type":"text","marks":[{"type":"code"}]},{"text":" data-point. This data-point is used to determine the \"type\" of this message. Output plugins or compute plugins can subscribe to messages by referring to the ","type":"text"},{"text":"IngressKey","type":"text","marks":[{"type":"code"}]},{"text":". Please note, that InputPlugins and ComputePlugins can create messages with various ","type":"text"},{"text":"IngressKey","type":"text","marks":[{"type":"code"}]},{"text":"- they are not limited to a single message-type. However, it is mentioned that for most use-cases a single ","type":"text"},{"text":"IngressKey","type":"text","marks":[{"type":"code"}]},{"text":" per plugin is sufficient.","type":"text"}]},{"type":"paragraph","content":[{"text":"Below you find a rather advanced example, showing how several input plugins, a compute plugin and several output plugins interact.","type":"text"}]},{"type":"mediaSingle","attrs":{"layout":"center","width":614,"widthType":"pixel"},"content":[{"type":"media","attrs":{"width":1989,"id":"07360f2a-f77d-4fb6-9ead-c3a17acb8b89","collection":"contentId-4128931852","type":"file","height":534}},{"type":"caption","content":[{"text":"Senseforce Edge streaming architecture","type":"text"}]}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Input Plugin 1 ","type":"text","marks":[{"type":"strong"}]},{"text":"creates messages with ","type":"text"},{"text":"IngressKey = msg1","type":"text","marks":[{"type":"strong"}]},{"text":". ","type":"text"},{"text":"Output Plugin 1 ","type":"text","marks":[{"type":"strong"}]},{"text":"is subscribed to messages with this ","type":"text"},{"text":"IngressKey","type":"text","marks":[{"type":"strong"}]},{"text":". This means, all messages from ","type":"text"},{"text":"Input Plugin 1 ","type":"text","marks":[{"type":"strong"}]},{"text":"are directly sent to ","type":"text"},{"text":"Output Plugin 1.","type":"text","marks":[{"type":"strong"}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Input Plugin 2","type":"text","marks":[{"type":"strong"}]},{"text":" creates two messages, one with ","type":"text"},{"text":"IngressKey = msg2","type":"text","marks":[{"type":"strong"}]},{"text":" and one with ","type":"text"},{"text":"IngressKey = msg3","type":"text","marks":[{"type":"strong"}]},{"text":".","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Both messages are sent to the ","type":"text"},{"text":"Compute Plugin 1","type":"text","marks":[{"type":"strong"}]},{"text":", as the plugin is subscribed to both IngressKeys.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Messages with ","type":"text"},{"text":"IngressKey = msg3","type":"text","marks":[{"type":"strong"}]},{"text":" are at the same time sent to ","type":"text"},{"text":"Output Plugin 2","type":"text","marks":[{"type":"strong"}]},{"text":".","type":"text"}]}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Compute Plugin 1","type":"text","marks":[{"type":"strong"}]},{"text":" then creates messages with an ","type":"text"},{"text":"IngressKey = msg4","type":"text","marks":[{"type":"strong"}]},{"text":", which is than sent to ","type":"text"},{"text":"Output Plugin 2","type":"text","marks":[{"type":"strong"}]},{"text":", as this plugin is subscribed to ","type":"text"},{"text":"IngressKey = msg4","type":"text","marks":[{"type":"strong"}]},{"text":". A real-life example might be, that the compute plugin combines values from both msg3 and msg2 and creates one combined data stream msg4.","type":"text"}]}]}]},{"type":"heading","attrs":{"level":3},"content":[{"text":"Configuring the data routing","type":"text"}]},{"type":"paragraph","content":[{"text":"Similar to data routing between Input- and Output-plugins, use the ","type":"text"},{"text":"EventDefinition.xml","type":"text","marks":[{"type":"code"}]},{"text":" configuration file to define, which messages are routed to which plugin.","type":"text"}]},{"type":"paragraph","content":[{"text":"See the Senseforce manual for Edge data routing to get a basic understanding of the data rouging mechanisms: ","type":"text"},{"text":"Edge Data Routing (EventDefinition.xml) - Senseforce 2.0 Manual","type":"text","marks":[{"type":"link","attrs":{"href":"https://manual.senseforce.io/manual/senseforce-edge/edge-configuration/edge-data-routing-eventdefinition.xml"}}]}]},{"type":"paragraph","content":[{"text":"To understand, how compute plugin data routing works, let’s consider the following sample file. In the example description, it is referred to the name of plugins. The plugin’s names are defined in the ","type":"text"},{"text":"appsettings.xml","type":"text","marks":[{"type":"code"}]},{"text":" file where you load the plugins. See the first chapter in this manual for more details.","type":"text"}]},{"type":"codeBlock","content":[{"text":"\n\n \n \n \n Compute_demo\n Mqtt_senseforce\n \n Hello\n \n $(Timestamp)\n MDE10\n $(GUID)\n \n $(Id)\n $(SawArea)\n $(CutLength)\n $(MachineNumber)\n \n my_$(Material)_in\n \n \n \n \n \n Mqtt_senseforce\n \n Compute_demo_key\n \n $(Timestamp)\n ComputedType\n $(GUID)\n \n $(Measurement)\n \n \n \n \n","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"This example defines two data mappings (see line 5 to 24 for the first and line 25 to 38 for the second mapping).","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Each mapping actually represents one subscription in the sketch above (see sketch “Edge data mapping” above). ","type":"text"},{"text":"(Note: Input plugins and compute plugin outputs are automatically connected to the Stream processor. Therefore, you only need to define the subscription)","type":"text","marks":[{"type":"strong"},{"type":"em"}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"The first mapping is used to to create subscriptions for Plugins with the name “Mqtt_senseforce” and “Compute_demo” (see lines 6 to 8 ). The subscription is created for messages with the “IngressKey = Hello” (see line 10). Meaning, all messages which arrive at the stream processor with the “IngressKey = Hello” are redirected to both, “Mqtt_senseforce” and “Compute_demo”.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"The second mapping creates a subscription again for the Plugin “Mqtt_senseforce”, for all messages with “IngressKey = Compute_demo_key”. Meaning, all messages arriving at the stream processor with the IngressKey = Compute_demo_key are redirected to “Mqtt_senseforce”.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"The lines in the ","type":"text"},{"text":"Event","type":"text","marks":[{"type":"code"}]},{"text":" - xml-tags are defining how the message looks like. This is the same for “normal” input plugins as well as compute plugins and is described here: ","type":"text"},{"text":"Edge Data Routing (EventDefinition.xml) - Senseforce 2.0 Manual","type":"text","marks":[{"type":"link","attrs":{"href":"https://manual.senseforce.io/manual/senseforce-edge/edge-configuration/edge-data-routing-eventdefinition.xml"}}]}]}]}]},{"type":"paragraph","content":[{"text":"Combining both examples (","type":"text"},{"text":"EventDefinition.xml","type":"text","marks":[{"type":"code"}]},{"text":" and ","type":"text"},{"text":"appsettings.xml","type":"text","marks":[{"type":"code"}]},{"text":") provides the following Edge situation:","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"We load the following plugins (see ","type":"text"},{"text":"appsettings.xml","type":"text","marks":[{"type":"code"}]},{"text":")","type":"text"}]},{"type":"bulletList","content":[{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Output Plugin","type":"text","marks":[{"type":"strong"}]},{"text":": Mqtt-Plugin with the name “Mqtt_senseforce” (see line 6 to 10)","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Input Plugin","type":"text","marks":[{"type":"strong"}]},{"text":": HelloWorld-Plugin with the name “HelloWorld” (see line 20 to 24)","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Compute Plugin","type":"text","marks":[{"type":"strong"}]},{"text":": HelloWorldCompute-Plugin with the name “Compute_demo” (see line 13 to 17)","type":"text"}]}]}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"The compute plugin subscribes to all messages with IngressKey = Hello.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"The output plugin subscribes to all messages with IngressKey = Hello and IngressKey = Compute_demo_key.","type":"text"}]}]},{"type":"listItem","content":[{"type":"paragraph","content":[{"text":"Assuming, that the Input plugin creates messages with IngressKey = Hello and the compute plugin generates messages with IngressKey = Compute_demo_key, the following architecture is configured:","type":"text"}]}]}]},{"type":"paragraph"},{"type":"mediaSingle","attrs":{"layout":"center","width":660,"widthType":"pixel"},"content":[{"type":"media","attrs":{"width":1890,"id":"49b69b39-33ba-4f36-a8e9-0671a51609d0","collection":"contentId-4128931852","type":"file","height":542}},{"type":"caption","content":[{"text":"Senseforce edge example plugin data routing","type":"text"}]}]},{"type":"panel","attrs":{"panelType":"success"},"content":[{"type":"paragraph","content":[{"text":"For this example to work, the Input plugin “","type":"text"},{"text":"HelloWorld","type":"text","marks":[{"type":"strong"}]},{"text":"” needs to create messages with an ","type":"text"},{"text":"IngressKey = Hello","type":"text","marks":[{"type":"code"}]},{"text":". And the “","type":"text"},{"text":"Compute_demo","type":"text","marks":[{"type":"strong"}]},{"text":"” - plugin needs to create messages with ","type":"text"},{"text":"IngressKey = Compute_demo_key","type":"text","marks":[{"type":"code"}]},{"text":".","type":"text"}]}]}],"version":1}

Browser not supported