Difference between revisions of "M2M Bridge"

Revision as of 14:52, 19 April 2016

Functionality

• Configurable edge intelligence
• Bridges standard and proprietary protocols to AMTech IoT DAP.
  • MQTT, LLRP, CoAP, STOMP, SmartM2M, LWM2M, PLC, Zigbee and others
• Device-to-device or device-to-cloud communications.
• Allow remote and centralized administration of IoT devices and gateways.
  • SNMP/MIB/TRAP and other
• Configurable auto-discover
• Implements common functionality and orchestrates the execution of the protocols
• Network failure detection and recovery
• Get centralized configuration information at startup and real time modifications
• Access control policies to manage observation production and consumption
• The following diagram illustrates a M2MBrdige configuration:
  • Using LLRP protocol to get the data from EPC tags and send commands to the reader
  • Using SNMP to monitor the health o the readers
  • Implementing smoothing, decoding, grouping, access control and other edge intelligence

Edge Configuration

• bridgeConfig.json located at M2MBridge.js directory

   {
   //text to be assigned to M2MBridges description property
   "description": "AMTech M2M Bridge", 
   //if the description property will be assigned to M2MBridge's linked things
   "description:children" : true,
       "dap":{
           //amtech IoT DAP ur
           "dapUrl": "https://dap.amtech.mx",     
           //userid for the m2mBridge instance bridgeId 
           "userId": "xxxxxxx@amtech.mx",
           // tenant where bridge been configured       
           "tenant" : "xxxxxxx",  
           //m2mBridge userId password  
           "password" :"xxxxxxxx"
       },
        //M2MBridge instance id to be cloned
       "templateId":"m2mCreator:m2mBridge",
       //Prefix to add to the unique M2MBridge identifier, the mac address of the device is use as unique id
       //In absence of the prefix just the mac address is used as identifier
       "bridgeIdPrefix":"tienda1",       
        //wkt location to set m2mBridge location overrides address
       "location": "{\"wkt\":\"POINT(-99.17125583 19.40501031)\",\"sContext\":\"geo\"}",  
       //if the location property will be assigned to M2MBridge's linked things
       "location:children" : true,
       //Address to be used to get m2mBridge's location
       "address" :{				 
           "country" : "usa",
           "city": "Las Vegas",
           "road": "Las Vegas Boulevard South",
           "number":"3960"
       },
   }

Cloud Configuration

• Create an amtechM2mBridge instance (See "/amtech/linkeddata/types/composite/entity/amtechM2mBridge")
• Create an actor actorX with the polices required by the activity(s) (See Actors)
  • Add the things type polices the bridge needs to the actor actorX
• Register a follower (See Roles)
  • Assign to follower actor actorX access
• Activity observation configuration (See Observation production configuration)
  • Add the Things types the bridge will use (See Thing types)
    • Add the observations types from selected thing type the bridge will produce or consume (See Observations and observation types CRUD observations)
  • Configure the topic that m2mBridge will listen for crud and command observations has to matched with others things' observation production configuration linked to this m2mBridge configuration (See Observation production configuration Topics)
• Things instance creation
  • Configuring autoDiscover (See Edge Configuration)
    • The bridge will request the DAP to clone templateId instance with the name convention bridgeIdPrefix:(device mac address) from bridgeConfig.json
    • the things instances linked to the templateId property bridgeInstances will be cloned with the name convention bridgeIdPrefix:(device mac address):thing._name from bridgeConfig.json
    • cloned instance will be giving the access control owner to the follower user id of the bridge that requested it.
• Monitoring M2MBridge status
  • Create an SNMPDevice instance and give access to your M2MBridge actor (See "/amtech/linkeddata/types/composite/entity/SNMPDevice")
    • Send observations to /m2mBridge/snmp/read a core activity /amtech/activities/monitorM2MBridgeStatus will analyze the data and notify to the user and guestusers of the M2MBridge instance.
      • This get done by setting at the observation production configuration /observationproductionconfig/SNMPDevice/observationsproducedconfig/snmpRead topic to value /m2mBridge/snmp/ (See Observation production configuration)

Implementation notes

• M2MBridge is an open source stack developed by the AMTEch team; it discovers and loads nodes modules implementing "M2MBridge plugin interface"(See Thing types) tacking into account thing instances, activity(s) observation production configuration (See Observation production configuration) and M2MBridge credentials (See Actors and Edge Configuration).
  • It leverages AMTech IoT DAP (See Integration Guideline)
    • Clone configuration from exiting M2MBridge template configuration (See Edge Configuration)
    • Gets observation production configuration (See Observation production configuration API)
    • Gets thing types instances (See Observation instances API)
    • Creates a web socket to receive asynchronous commands and thing instances changes (crud operations) (See CRUD and Commands API)
      • Dispatch command observations to plugin instance leveraging thing type instance @id (See Thing types)
      • Restart instance when supported properties change by calling stop and star plugin interface
    • Creates configuration information by Thing type leveraging configuration information and client side M2MBridge placeholders (See Observation production configuration and Placeholders)
    • Load plugin nodes modules required by configuration
    • Creates an instance of plugin for each thing type instance using instance @id as identifier (See Thing types)
      • JavaScript object is extended with the properties values from the thing instance (See plugin example )
      • Properties and methods are injected: (See for details)
        • common logger
        • methods to send observations with and without enrichment
        • methods for restarting plugin
    • Creates a centralized observation dispatcher with persistence to ensure:
      • Observations delivery in the order that observations occurred .

How to implement a new plugin

• Clone git repository (https://github.com/AMTechMX/M2MBridge.git)
  • at /.../M2MBridge/plugins create a directory that matched with the Thing type name to bridge example SNMPDevice (See Thing types)
• Create a thing type XXXDevice (See Thing types)
• Create the observations type the thing XXXDevice produces or consumes, example XXXDeviceObserv1 (See Observations and observation types)
• Associate the observation XXXDeviceObserv1 type to the XXXDevice
• Implement a nodejs module with the following interface

   function XXXThing() {
   }
   XXXThing.prototype.start = function ( complete) {
       try {
           complete(null);
       } catch (e) {
           complete(e);
       }
   };
   XXXThing.prototype.stop = function (complete) {
       try {
           complete(null);
       } catch (e) {
           complete(e);
       }
   };
   XXXThing.prototype.command = function (observation, complete) {
       try {
           complete(null);
       } catch (e) {
           complete(e);
       }
   };
   module.exports.XXXThing = XXXThing;

How to install it

• Clone git repository (https://github.com/AMTechMX/M2MBridge.git)
• Install nodejs https://nodejs.org/en/download/package-manager/
• Install npm (http://blog.npmjs.org/post/85484771375/how-to-install-npm)
• Delete at /.../M2MBridge/plugins/xxx unneeded plug-ins (optional)
• Install packages for m2mBridge core and plug-ins (https://docs.npmjs.com/cli/install:)
• Execute npm install at:
  • M2MBridge directory
  • each plug-in directory

Existing plugins (See exiting plugins (work on process))

LLRPReader

Bridge EPC Low Level reader protocol to IoT DAP

• Edge Intelligence
  • Implementing smoothing to new and lost tag
  • EPC decoding
  • Groups tags read by antennas groups
  • Groups tags by EPC decoding.
• Placeholders
  • -#{antennaId} Llrp protocol antenna Id mapped at antennas supported property
  • -#{smoothingResult} if smoothing has been set to true LLRP reader observations can be sent to a topic depending of the smoothing process result
  • -#{llrpReaderProximity} Set the llrp reader proximity area supported property value to targetThing proximity value field
  • -#{antennaProximity} Set the llrp antenna proximity area supported property value to targetThing proximity value field
  • -#{tagEncoding} EPC encoding name
  • A component of decoded epc tag; helpful to organize epc observations; for example company-prefix to inform companies about products arrival or set access control.
    • -#{epcUri|companyPrefix|itemReference|serialNumber|serialReference|locationReference|extension|assetType|individualAssetReference|serviceReference|documentType|managerNumber|objectClass|cAGEOrDODAAC}

BLEPeripheralsScanner

BLEbeaconsScanner

SNMPDevice

MQTTBroker

COAP