init

.gitignore

+yarn.lock
+node_modules
+.idea

.gitlab-ci.yml

+deploy:
+  stage: deploy
+  only:
+    - tags
+  variables:
+    SERVICE_GROUP: "openapi"
+    SERVICE_NAME: "openapi-test"
+    PUBLISH_PORT: "31001"
+  script:
+    - export IMAGE_TAG=$SERVICE_NAME:$CI_COMMIT_REF_NAME
+    - docker build -t $IMAGE_TAG .
+    - sed -i 's/SERVICE_NAME/'$SERVICE_NAME'/' docker-compose.yml
+    - docker stack deploy -c docker-compose.yml $SERVICE_GROUP

Dockerfile

+FROM registry.cn-hangzhou.aliyuncs.com/ugen-app/ugen-core:4.2.2
+WORKDIR /data
+COPY ./package.json .
+RUN yarn --regsitry=http://192.168.2.91:7001
+COPY . .
+COPY core /data/node_modules/iot-cloud-core/core
+CMD node start.js
+

config.js

+const path = require('path');
+module.exports = {
+  port: 3000,
+  provider: require(path.resolve('src','Provider.js')),
+  needLog: false,
+  customUrl: 'iot/ali',
+  componentName: 'openapi-test',
+  communications:[
+    'HTTPCOM',
+  ]
+};

docker-compose.yml

+version: '3.7'
+services:
+  SERVICE_NAME:
+    image: ${IMAGE_TAG}
+    ports:
+      - "${PUBLISH_PORT}:3000"
+    deploy:
+      replicas: 1
+      update_config:
+        order: start-first
+      resources:
+        limits:
+          cpus: '0.5'
+          memory: 300M
+    environment:
+      ALI_KEY: ${ALI_KEY}
+      ALI_SECRET: ${ALI_SECRET}
+    networks:
+      - ugen
+
+networks:
+  ugen:
+    external: true

package.json

+{
+  "dependencies": {
+    "@alicloud/pop-core": "^1.7.9",
+    "iot-cloud-core": "^4.3.0"
+  },
+  "devDependencies": {
+    "babel-plugin-transform-decorators-legacy": "^1.3.5"
+  }
+}

src/Provider.js

+const Provider = require('iot-cloud-core').BASE.Provider;
+const public_class = require('./public/Public');
+class TESTProvider extends Provider{
+	constructor(){
+		super("test");
+		this.setPublicClass(public_class);
+	}
+}
+module.exports = TESTProvider;

src/Util/aliClient.js

+const Core = require('@alicloud/pop-core');
+
+module.exports = new Core({
+  accessKeyId: process.env.ALI_KEY,
+  accessKeySecret: process.env.ALI_SECRET,
+  endpoint: process.env.ALI_ENDPOINT || 'https://iot.cn-shanghai.aliyuncs.com',
+  apiVersion: process.env.ALI_APIVERSION || '2018-01-20'
+});

src/public/Public.js

+const PublicFunBase = require('iot-cloud-core').BASE.PublicFunBase;
+const aliClient = require('../Util/aliClient');
+
+
+class Public extends PublicFunBase{
+
+  async test(data){
+    this.checkKeyExists(data.params,"ProductKey","DeviceName","MessageContent");
+    let MessageContent = Buffer.from(data.params.MessageContent).toString('base64');
+    let params = {
+      "RegionId": "cn-shanghai",
+      "ProductKey": data.params.ProductKey,
+      "TopicFullName": `/a1zxV8TuyOr/${data.params.DeviceName}/user/down_raw`,
+      "MessageContent": MessageContent
+    };
+    // https://help.aliyun.com/document_detail/69793.html?spm=a2c4g.11186623.6.819.540d6a9bJZWNxu
+    try{
+      let res = await aliClient.request('Pub', params, {method: 'POST'});
+      if(res && res.Success){
+        return {
+          Success: true
+        }
+      }else{
+        return res;
+      }
+    }catch (e) {
+      // 阿里iot请求失败 如topic错误等原因
+      if(e.name){
+        return e.name
+      }else{
+        return 'request iot error'
+      }
+    }
+  }
+}
+module.exports = Public;

start.js

+require("babel-register")({
+    ignore: /node_modules\/(?!iot-cloud-publicAPI)/
+});
+const SuperServer = require('iot-cloud-core').SERVER.SuperServer;
+
+
+const config = require('./config');
+new SuperServer(config).start();