場景說明
華為云設(shè)備接入IoTDA服務(wù)對(duì)于設(shè)備上報(bào)的數(shù)據(jù),可以選擇讓平臺(tái)將設(shè)備上報(bào)數(shù)據(jù)推送給應(yīng)用服務(wù)器,由應(yīng)用服務(wù)器進(jìn)行保存;還可以選擇讓平臺(tái)將設(shè)備上報(bào)數(shù)據(jù)轉(zhuǎn)發(fā)給分布式消息服務(wù)(Kafka),由Kafka進(jìn)行存儲(chǔ)。
本示例為將所有設(shè)備上報(bào)的數(shù)據(jù)轉(zhuǎn)發(fā)至Kafka存儲(chǔ)。
購買Kafka實(shí)例
- 登錄華為云官方網(wǎng)站,訪問分布式消息服務(wù)。
- 單擊“進(jìn)入控制臺(tái)”進(jìn)入分布式消息服務(wù)管理控制臺(tái)。
- 單擊右上角“購買Kafka實(shí)例”,根據(jù)需求選擇實(shí)例規(guī)格與配置安全組后,單擊“立即購買”。
圖1 購買Kafka實(shí)例

配置 設(shè)備接入服務(wù)
在設(shè)備接入服務(wù)中創(chuàng)建產(chǎn)品模型、注冊(cè)設(shè)備并設(shè)置數(shù)據(jù)轉(zhuǎn)發(fā)規(guī)則,實(shí)現(xiàn)當(dāng)設(shè)備上報(bào)數(shù)據(jù)時(shí)將數(shù)據(jù)轉(zhuǎn)發(fā)至Kafka。
- 訪問設(shè)備接入服務(wù),單擊“立即使用”進(jìn)入設(shè)備接入控制臺(tái)。
- 在左側(cè)導(dǎo)航欄選擇“規(guī)則>數(shù)據(jù)轉(zhuǎn)發(fā)”,單擊右上角的“創(chuàng)建規(guī)則”。
- 參考下表參數(shù)說明,填寫規(guī)則內(nèi)容。以下參數(shù)取值僅為示例,您可參考用戶指南創(chuàng)建自己的規(guī)則,填寫完成后單擊“創(chuàng)建規(guī)則”。
參數(shù)名
參數(shù)說明
規(guī)則名稱
自定義,如iotda-kafka。
規(guī)則描述
自定義,如數(shù)據(jù)轉(zhuǎn)發(fā)至Kafka存儲(chǔ)。
數(shù)據(jù)來源
選擇“設(shè)備屬性”。
觸發(fā)事件
自動(dòng)匹配“設(shè)備屬性上報(bào)”。
資源空間
選擇“所有資源空間”。
圖2 創(chuàng)建數(shù)據(jù)轉(zhuǎn)發(fā)規(guī)則
- 單擊“設(shè)置轉(zhuǎn)發(fā)目標(biāo)”頁簽,單擊“添加”,設(shè)置轉(zhuǎn)發(fā)目標(biāo)。
參數(shù)名
參數(shù)說明
轉(zhuǎn)發(fā)目標(biāo)
選擇“分布式消息服務(wù)(kafka)”
區(qū)域
選擇Kafka服務(wù)的所在區(qū)域。若未授權(quán)訪問此區(qū)域的服務(wù),請(qǐng)根據(jù)界面提示,配置云服務(wù)訪問授權(quán)。
對(duì)接地址
參考連接已開啟SASL的Kafka專享版實(shí)例獲取對(duì)接地址。設(shè)備接入基礎(chǔ)版和標(biāo)準(zhǔn)版實(shí)例只支持公網(wǎng)接入專享版Kafka,企業(yè)版實(shí)例支持私網(wǎng)接入專享版Kafka。
主題
自定義主題,參考創(chuàng)建Topic。
若開啟數(shù)據(jù)加密傳輸,SASL用戶名和密碼,填寫您在購買Kafka實(shí)例中輸入的SASL用戶名和密碼。
SASL用戶名
填寫您在購買Kafka實(shí)例中輸入的SASL用戶名。
密碼
填寫您在購買Kafka實(shí)例中輸入的密碼。
圖3 創(chuàng)建數(shù)據(jù)轉(zhuǎn)發(fā)目標(biāo)
- 單擊“啟動(dòng)規(guī)則”,激活配置好的數(shù)據(jù)轉(zhuǎn)發(fā)規(guī)則。
圖4 激活規(guī)則

驗(yàn)證操作
- 您可以使用配置設(shè)備接入服務(wù)時(shí)注冊(cè)的真實(shí)設(shè)備接入平臺(tái),上報(bào)任意數(shù)據(jù)。
- 您也可以使用模擬器模擬設(shè)備上報(bào)數(shù)據(jù),操作方法請(qǐng)參考在線開發(fā)MQTT協(xié)議的智慧路燈。
期望結(jié)果:
登錄Kafka管理控制臺(tái),單擊Kafka實(shí)例名進(jìn)入實(shí)例管理頁面后,在“消息查詢”頁面可以查看到設(shè)備上報(bào)的數(shù)據(jù)。

您也可以使用Kafka的API(查詢消息)進(jìn)行文件讀取。
最新文章
- 華為云設(shè)備接入IoTDA介紹_物聯(lián)網(wǎng)廠家有哪些_物聯(lián)網(wǎng)的應(yīng)用
- Kafka架構(gòu)_Kafka如何實(shí)現(xiàn)負(fù)載均衡_Kafka數(shù)據(jù)存儲(chǔ)方式-華為云
- 華為云IoT設(shè)備接入服務(wù)介紹_物聯(lián)網(wǎng)平臺(tái)_物聯(lián)網(wǎng)設(shè)備接入方案
- 設(shè)備接入服務(wù)怎么用_華為云IoT設(shè)備接入_設(shè)備接入管理平臺(tái)
- kafka是什么_kafka介紹_分布式消息服務(wù)Kafka版
- 分布式消息系統(tǒng)Kafka_分布式消息系統(tǒng)_分布式消息kafka可以解決什么問題-華為云