forked from community/device-mgt-plugins
charitha
6 years ago
parent
adc1e32361
commit
b06f608c8f
@ -1,42 +0,0 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!--
|
||||
~ Copyright (c) 2017, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
|
||||
~
|
||||
~ WSO2 Inc. licenses this file to you under the Apache License,
|
||||
~ Version 2.0 (the "License"); you may not use this file except
|
||||
~ in compliance with the License.
|
||||
~ You may obtain a copy of the License at
|
||||
~
|
||||
~ http://www.apache.org/licenses/LICENSE-2.0
|
||||
~
|
||||
~ Unless required by applicable law or agreed to in writing,
|
||||
~ software distributed under the License is distributed on an
|
||||
~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
||||
~ KIND, either express or implied. See the License for the
|
||||
~ specific language governing permissions and limitations
|
||||
~ under the License.
|
||||
-->
|
||||
|
||||
<eventPublisher name="WSO2IoT-DeviceOperation-Publisher" xmlns="http://wso2.org/carbon/eventpublisher">
|
||||
<from streamName="org.wso2.iot.operation" version="1.0.0"/>
|
||||
<mapping customMapping="enable" type="text">
|
||||
<inline>
|
||||
{
|
||||
"deviceIdentifiers": {{meta_deviceIdentifiers}},
|
||||
"deviceType": "{{meta_deviceType}}",
|
||||
"operation": {
|
||||
"code": "{{code}}",
|
||||
"type": "{{type}}",
|
||||
"status": "PENDING",
|
||||
"isEnabled": "{{isEnabled}}",
|
||||
"payLoad": "{{payLoad}}"
|
||||
}
|
||||
}
|
||||
</inline>
|
||||
</mapping>
|
||||
<to eventAdapterType="oauth-http">
|
||||
<property name="http.client.method">HttpPost</property>
|
||||
<property name="http.url">https://localhost:9443/api/device-mgt/v1.0/devices/{deviceType}/operations</property>
|
||||
<property name="http.url.templated">true</property>
|
||||
</to>
|
||||
</eventPublisher>
|
||||
@ -0,0 +1,16 @@
|
||||
/* Enter a unique ExecutionPlan */
|
||||
@Plan:name('WSO2IoT-Operation-ExecutionPlan')
|
||||
|
||||
/* Enter a unique description for ExecutionPlan */
|
||||
@Plan:description('Publish operations to devices coming from org.wso2.iot.operation stream')
|
||||
|
||||
/* define streams/tables and write queries here ... */
|
||||
|
||||
@Plan:trace('false')
|
||||
|
||||
@Import('org.wso2.iot.operation:1.0.0')
|
||||
define stream dataIn (meta_deviceIdentifiers string, meta_deviceType string, code string, type string, isEnabled bool, payLoad string);
|
||||
|
||||
from dataIn#device:addOperation(meta_deviceIdentifiers, meta_deviceType, code, type, isEnabled, payLoad)
|
||||
select *
|
||||
insert into drop;
|
||||
@ -0,0 +1,23 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!--
|
||||
~ Copyright (c) 2018, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
|
||||
~
|
||||
~ WSO2 Inc. licenses this file to you under the Apache License,
|
||||
~ Version 2.0 (the "License"); you may not use this file except
|
||||
~ in compliance with the License.
|
||||
~ You may obtain a copy of the License at
|
||||
~
|
||||
~ http://www.apache.org/licenses/LICENSE-2.0
|
||||
~
|
||||
~ Unless required by applicable law or agreed to in writing,
|
||||
~ software distributed under the License is distributed on an
|
||||
~ "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
||||
~ KIND, either express or implied. See the License for the
|
||||
~ specific language governing permissions and limitations
|
||||
~ under the License.
|
||||
-->
|
||||
|
||||
<artifact name= "WSO2IoT-Operation-ExecutionPlan" version="1.0.0" type="event/execution-plan" serverRole="DataAnalyticsServer">
|
||||
<file>WSO2IoT-Operation-ExecutionPlan.siddhiql</file>
|
||||
</artifact>
|
||||
|
||||
@ -0,0 +1,16 @@
|
||||
/* Enter a unique ExecutionPlan */
|
||||
@Plan:name('WSO2IoT-GeoAlerts-ExecutionPlan')
|
||||
|
||||
/* Enter a unique description for ExecutionPlan */
|
||||
@Plan:description('To convert the WSO2 IoT event incoming stream to relavant streams')
|
||||
|
||||
/* define streams/tables and write queries here ... */
|
||||
|
||||
@Plan:trace('false')
|
||||
|
||||
@Import('iot.per.device.stream.geo.AlertNotifications:1.0.0')
|
||||
define stream dataIn (id string, owner string, state string, information string, timeStamp long, latitude double, longitude double, type string);
|
||||
|
||||
from dataIn#device:addNotification(id, type, information)
|
||||
select *
|
||||
insert into ignore;
|
||||
13
components/analytics/iot-analytics/org.wso2.carbon.device.mgt.iot.analytics/src/main/resources/carbonapps/device_analytics/WSO2IoT-DeviceOperation-Publisher_1.0.0/artifact.xml → components/analytics/iot-analytics/org.wso2.carbon.iot.geo.dashboard/src/main/resources/carbonapps/WSO2IoT-GeoAlerts-ExecutionPlan_1.0.0/artifact.xml
13
components/analytics/iot-analytics/org.wso2.carbon.device.mgt.iot.analytics/src/main/resources/carbonapps/device_analytics/WSO2IoT-DeviceOperation-Publisher_1.0.0/artifact.xml → components/analytics/iot-analytics/org.wso2.carbon.iot.geo.dashboard/src/main/resources/carbonapps/WSO2IoT-GeoAlerts-ExecutionPlan_1.0.0/artifact.xml
Loading…
Reference in new issue