> 北向接口對(duì)接，分主動(dòng)推送(實(shí)時(shí))、主動(dòng)拉取(查詢/歷史)兩大類，工業(yè)項(xiàng)目一般組合使用，禁止直接讀IoT平臺(tái)數(shù)據(jù)庫(kù)。

一、4種主流接口對(duì)接方案

1. Webhook(HTTPS推送，中小流量實(shí)時(shí))

IoT平臺(tái)規(guī)則引擎，過濾、清洗設(shè)備遙測(cè)、告警、設(shè)備上下線事件，POST推送到業(yè)務(wù)系統(tǒng)開放接口。

- 流程：設(shè)備上報(bào) → IoT平臺(tái)規(guī)則引擎過濾/轉(zhuǎn)換JSON → POST到業(yè)務(wù)系統(tǒng)API地址

- 鑒權(quán)：Header攜帶Token、簽名校驗(yàn);業(yè)務(wù)系統(tǒng)返回200代表接收成功，平臺(tái)自動(dòng)重試

- ?優(yōu)點(diǎn)：配置簡(jiǎn)單、開發(fā)量小;適合水務(wù)、照明、小型產(chǎn)線告警推送

- ?缺點(diǎn)：高并發(fā)下業(yè)務(wù)系統(tǒng)容易壓垮，重試會(huì)產(chǎn)生重復(fù)消息，必須做冪等去重

2. 服務(wù)端訂閱 MQTT / AMQP(高并發(fā)工業(yè)實(shí)時(shí)首選)

業(yè)務(wù)系統(tǒng)作為MQTT客戶端，長(zhǎng)連接訂閱IoT平臺(tái)北向Topic，持續(xù)消費(fèi)設(shè)備消息;可搭配Kafka/RocketMQ做消息緩沖。

- ?優(yōu)點(diǎn)：斷線續(xù)傳、消息ACK確認(rèn)、支持QoS，百萬測(cè)點(diǎn)不丟數(shù);支持雙向(下發(fā)控制指令給設(shè)備)

- ?缺點(diǎn)：業(yè)務(wù)側(cè)需要開發(fā)消費(fèi)客戶端，運(yùn)維成本高

- 適用：工廠MES、電力、海量傳感器、高可靠工業(yè)場(chǎng)景

3. RESTful開放API(業(yè)務(wù)系統(tǒng)主動(dòng)拉取，歷史+設(shè)備檔案)

業(yè)務(wù)系統(tǒng)定時(shí)調(diào)用IoT平臺(tái)HTTPS接口，按需查詢，不是實(shí)時(shí)推送

接口分類：

- 實(shí)時(shí)接口：查詢?cè)O(shè)備當(dāng)前最新屬性、在線狀態(tài)

- 歷史時(shí)序接口：按設(shè)備ID+起止時(shí)間，分頁(yè)拉取歷史遙測(cè)數(shù)據(jù)

- 設(shè)備檔案接口：設(shè)備列表、標(biāo)簽、分組、產(chǎn)品信息

- ?優(yōu)點(diǎn)：主動(dòng)權(quán)在業(yè)務(wù)系統(tǒng)，可斷點(diǎn)續(xù)拉，適合報(bào)表、日歸檔、BI

- ?缺點(diǎn)：輪詢有延遲，高頻調(diào)用會(huì)觸發(fā)平臺(tái)限流

4. WebSocket(大屏、監(jiān)控平臺(tái)，輕量實(shí)時(shí))

長(zhǎng)連接，平臺(tái)主動(dòng)推送設(shè)備狀態(tài)變化;適合監(jiān)控大屏、后臺(tái)實(shí)時(shí)看板，不適合海量設(shè)備高并發(fā)場(chǎng)景

> 補(bǔ)充：OPC UA，工廠場(chǎng)景對(duì)接SCADA、MES常用，偏工業(yè)總線側(cè)，屬于邊緣北向?qū)?/p>

二、完整落地對(duì)接步驟

1. 需求與字段定義

確定對(duì)接數(shù)據(jù)：遙測(cè)值、告警、設(shè)備生命周期;約定JSON結(jié)構(gòu)、時(shí)間戳(UTC優(yōu)先)、單位;區(qū)分實(shí)時(shí)流和歷史歸檔。

2. 開通平臺(tái)應(yīng)用憑證

在IoT平臺(tái)創(chuàng)建應(yīng)用，獲取 `AccessKey/SecretKey` 或Token，分配數(shù)據(jù)權(quán)限(按產(chǎn)品/設(shè)備分組隔離)。

3. 網(wǎng)絡(luò)打通

- 公網(wǎng)：全部HTTPS/TLS加密，IP白名單;

- 企業(yè)內(nèi)網(wǎng)：VPC、專線、VPN，不暴露公網(wǎng)端口。

4. 接口方案開發(fā)

- 推送方案：業(yè)務(wù)系統(tǒng)開發(fā)接收接口，做好消息ID冪等、日志、異常告警;

- 拉取方案：業(yè)務(wù)系統(tǒng)寫定時(shí)任務(wù)，分頁(yè)+增量時(shí)間戳拉取，避免重復(fù)。

5. IoT平臺(tái)側(cè)配置

新建規(guī)則引擎，設(shè)置Topic過濾、字段轉(zhuǎn)換腳本，配置轉(zhuǎn)發(fā)目標(biāo)地址與鑒權(quán)。

6. 聯(lián)調(diào)測(cè)試

單設(shè)備模擬上報(bào)、斷網(wǎng)重試、壓力測(cè)試、重復(fù)消息測(cè)試，校驗(yàn)數(shù)據(jù)完整性。

7. 上線運(yùn)維

監(jiān)控消息量、失敗率、接口延遲;設(shè)置失敗告警、消息堆積告警。

三、核心風(fēng)險(xiǎn)點(diǎn)(對(duì)接最容易踩坑)

1. 消息重復(fù)：平臺(tái)重試機(jī)制會(huì)重復(fù)推送，業(yè)務(wù)系統(tǒng)必須用messageId做冪等，避免重復(fù)入庫(kù)

2. 超時(shí)堆積：Webhook業(yè)務(wù)接口響應(yīng)慢，平臺(tái)消息堆積，建議高并發(fā)改用MQTT+消息隊(duì)列解耦

3. 鑒權(quán)過期：Token定時(shí)刷新機(jī)制要處理，防止接口突然鑒權(quán)失敗

4. 時(shí)區(qū)問題：時(shí)間戳不統(tǒng)一會(huì)造成歷史數(shù)據(jù)錯(cuò)亂，統(tǒng)一UTC時(shí)間

5. 限流：REST API大量拉歷史數(shù)據(jù)，必須分頁(yè)+限速，防止被平臺(tái)封禁

四、聚英物聯(lián)網(wǎng)平臺(tái)接口對(duì)接要點(diǎn)

1. 標(biāo)準(zhǔn)云服務(wù)：智能終端設(shè)備標(biāo)配聚英物聯(lián)網(wǎng)平臺(tái)進(jìn)行遠(yuǎn)程數(shù)據(jù)監(jiān)控，支持通過監(jiān)控中心大屏顯示，手機(jī)APP實(shí)時(shí)移動(dòng)監(jiān)控，可實(shí)現(xiàn)農(nóng)業(yè)、工業(yè)自動(dòng)化、環(huán)境監(jiān)測(cè)、水利水電、智慧工地、畜禽養(yǎng)殖、水產(chǎn)養(yǎng)殖等場(chǎng)景一體化監(jiān)控，監(jiān)控平臺(tái)標(biāo)題可用戶自定義設(shè)置。

2. API接口開發(fā)：使用聚英物聯(lián)網(wǎng)平臺(tái)提供的API接口，用戶根據(jù)自己的業(yè)務(wù)應(yīng)用需求開發(fā)前端軟件比如小程序，app，WEB平臺(tái)，PC端軟件等，服務(wù)器端與智能終端設(shè)備的通訊交互，服務(wù)器運(yùn)維由聚英云農(nóng)完成，可以減少二次開發(fā)過程種80%的工作量和難度。

3. 私有化部署：平臺(tái)私有化，將聚英物聯(lián)網(wǎng)平臺(tái)部署到用戶自己的私有服務(wù)器上，完全由企業(yè)獨(dú)立自主管理，進(jìn)行商業(yè)化應(yīng)用。