6.2 KiB

Raw Permalink Blame History

Ikonekta ang iyong IoT device sa cloud - Virtual IoT Hardware at Raspberry Pi

Sa bahaging ito ng aralin, ikokonekta mo ang iyong virtual IoT device o Raspberry Pi sa iyong IoT Hub upang magpadala ng telemetry at tumanggap ng mga utos.

Ikonekta ang iyong device sa IoT Hub

Ang susunod na hakbang ay ikonekta ang iyong device sa IoT Hub.

Gawain - ikonekta sa IoT Hub

Buksan ang folder na soil-moisture-sensor sa VS Code. Siguraduhing tumatakbo ang virtual environment sa terminal kung gumagamit ka ng virtual IoT device.
Mag-install ng ilang karagdagang Pip packages:
```
pip3 install azure-iot-device
```
Ang azure-iot-device ay isang library para makipag-ugnayan sa iyong IoT Hub.
Idagdag ang sumusunod na imports sa itaas ng file na app.py, sa ibaba ng mga umiiral na imports:
```
from azure.iot.device import IoTHubDeviceClient, Message, MethodResponse
```
Ang code na ito ay nag-i-import ng SDK para makipag-ugnayan sa iyong IoT Hub.
Alisin ang linyang import paho.mqtt.client as mqtt dahil hindi na kailangan ang library na ito. Alisin ang lahat ng MQTT code kabilang ang mga pangalan ng topic, lahat ng code na gumagamit ng mqtt_client at ang handle_command. Panatilihin ang while True: loop, ngunit tanggalin ang linyang mqtt_client.publish mula sa loop na ito.
Idagdag ang sumusunod na code sa ibaba ng mga import statements:
```
connection_string = "<connection string>"
```
Palitan ang <connection string> ng connection string na nakuha mo para sa device kanina sa araling ito.

💁 Hindi ito ang pinakamahusay na kasanayan. Ang mga connection string ay hindi dapat itago sa source code, dahil maaaring ma-check in ito sa source code control at makita ng kahit sino. Ginagawa natin ito dito para sa layunin ng pagiging simple. Sa ideal na sitwasyon, dapat kang gumamit ng isang bagay tulad ng environment variable at isang tool tulad ng python-dotenv. Matututuhan mo pa ito sa susunod na aralin.

Sa ibaba ng code na ito, idagdag ang sumusunod upang lumikha ng isang device client object na maaaring makipag-ugnayan sa IoT Hub, at ikonekta ito:

device_client = IoTHubDeviceClient.create_from_connection_string(connection_string)

print('Connecting')
device_client.connect()
print('Connected')

Patakbuhin ang code na ito. Makikita mong nakakonekta ang iyong device.

pi@raspberrypi:~/soil-moisture-sensor $ python3 app.py 
Connecting
Connected
Soil moisture: 379

Magpadala ng telemetry

Ngayon na nakakonekta na ang iyong device, maaari kang magpadala ng telemetry sa IoT Hub sa halip na sa MQTT broker.

Gawain - magpadala ng telemetry

Idagdag ang sumusunod na code sa loob ng while True loop, bago ang sleep:
```
message = Message(json.dumps({ 'soil_moisture': soil_moisture }))
device_client.send_message(message)
```
Ang code na ito ay lumilikha ng isang IoT Hub Message na naglalaman ng soil moisture reading bilang isang JSON string, pagkatapos ay ipinapadala ito sa IoT Hub bilang isang device-to-cloud message.

Mag-handle ng mga utos

Kailangang mag-handle ng iyong device ng isang utos mula sa server code upang kontrolin ang relay. Ang utos na ito ay ipinapadala bilang isang direct method request.

Gawain - mag-handle ng direct method request

Idagdag ang sumusunod na code bago ang while True loop:
```
def handle_method_request(request):
    print("Direct method received - ", request.name)

    if request.name == "relay_on":
        relay.on()
    elif request.name == "relay_off":
        relay.off()    
```
Ang code na ito ay nagde-define ng isang method, handle_method_request, na tatawagin kapag may direct method na tinawag ng IoT Hub. Ang bawat direct method ay may pangalan, at inaasahan ng code na ito ang isang method na tinatawag na relay_on upang i-on ang relay, at relay_off upang i-off ito.

💁 Maaari rin itong ipatupad sa isang solong direct method request, na ipinapasa ang nais na estado ng relay sa isang payload na maaaring ipasa kasama ng method request at makukuha mula sa request object.
Ang mga direct method ay nangangailangan ng response upang ipaalam sa tumatawag na code na na-handle na ang mga ito. Idagdag ang sumusunod na code sa dulo ng function na handle_method_request upang lumikha ng response sa request:
```
method_response = MethodResponse.create_from_method_request(request, 200)
device_client.send_method_response(method_response)
```
Ang code na ito ay nagpapadala ng response sa direct method request na may HTTP status code na 200, at ipinapadala ito pabalik sa IoT Hub.
Idagdag ang sumusunod na code sa ibaba ng definition ng function na ito:
```
device_client.on_method_request_received = handle_method_request
```
Ang code na ito ay nagsasabi sa IoT Hub client na tawagin ang function na handle_method_request kapag may direct method na tinawag.

💁 Makikita mo ang code na ito sa code/pi o code/virtual-device folder.

😀 Ang iyong soil moisture sensor program ay nakakonekta na sa iyong IoT Hub!

Paunawa:
Ang dokumentong ito ay isinalin gamit ang AI translation service na Co-op Translator. Bagama't sinisikap naming maging tumpak, tandaan na ang mga awtomatikong pagsasalin ay maaaring maglaman ng mga pagkakamali o hindi pagkakatugma. Ang orihinal na dokumento sa kanyang katutubong wika ang dapat ituring na opisyal na sanggunian. Para sa mahalagang impormasyon, inirerekomenda ang propesyonal na pagsasalin ng tao. Hindi kami mananagot sa anumang hindi pagkakaunawaan o maling interpretasyon na dulot ng paggamit ng pagsasaling ito.

6.2 KiB Raw Permalink Blame History