Отправка сообщения в Azure Event Hub с помощью nodemcu - PullRequest
Новая
       89

Отправка сообщения в Azure Event Hub с помощью nodemcu

0 голосов
/ 24 февраля 2020

Я пытаюсь отправить сообщения на Azure Event Hub с помощью nodemcu (ESP8266). Я использую REST API Azure Event Hub. Я следовал этим инструкциям, однако у меня не получалось.

В настоящее время я получаю этот ответ: 401 SubCode = 40103: неверная подпись маркера авторизации

Я предоставил отпечаток пальца для соединения с HTTPS. (В учебнике не было необходимости, поэтому я немного запутался.)

Я с подозрением отношусь к SAS, но проверял снова и снова.

В качестве альтернативы я также намеревался использовать AMQP, но не смог найти библиотеку, которая его поддерживает.

Существуют ли альтернативные способы отправки сообщений в Event Hub. 

#include <WiFiClientSecure.h>
#include <String.h>
#include "sha256.h"
#include "Base64.h"

// START: Azure Evet Hub settings
const char* KEY = "<key>";    // event hub access key 
const char* KEY_NAME = "<key-name>";                 // event hub key name  ( policy name) 
const char* HOST = "<event-hub-namespace>.servicebus.windows.net";              // event hub name (name of service bus)
const char* END_POINT = "/<event-hub>/messages";                 // name of the evnthub which we create inside eventhub namespace
// END: Azure Evet Hub settings 

// START: WiFi settings
const char* SSID = "<ssid>";
const char* PASSWORD = "<password>";
// END: WiFi settings

String request;
String data;
String fullSas;
WiFiClientSecure client;

// Use web browser to view and copy
// SHA1 fingerprint of the certificate
const char fingerprint[] PROGMEM = "<fingerprint>";
void setup() {
  Serial.begin(115200);

  // START: Naive URL Encode
  String url = "https://" + (String)HOST + (String)END_POINT;
  url.replace(":", "%3A");
  url.replace("/", "%2F");
  Serial.println(url);
  // END: Naive URL Encode

  // START: Create SAS
  // https://azure.microsoft.com/en-us/documentation/articles/service-bus-sas-overview/
  // Where to get secods since the epoch: local service, SNTP, RTC
  int expire = 1609459200;
  String stringToSign = url + "\n" + expire;

  // START: Create signature
  Sha256.initHmac((const uint8_t*)KEY, 44);
  Sha256.print(stringToSign);
  char* sign = (char*) Sha256.resultHmac();
  int signLen = 32;
  // END: Create signature

  // START: Get base64 of signature
  int encodedSignLen = base64_enc_len(signLen);
  char encodedSign[encodedSignLen];
  base64_encode(encodedSign, sign, signLen); 
  String encodedSas = (String) encodedSign;
  // Naive URL encode
  encodedSas.replace("=", "%3D");
  //Serial.println(encodedSas);
  // END: Get base64 of signature

  // SharedAccessSignature
   fullSas = "sr=" + url + "&sig="+ encodedSas + "&se=" + expire +"&skn=" + KEY_NAME;
  // END: create SAS
//Serial.println("SAS below");
//Serial.println(fullSas);
//Serial.println();
  // START: Wifi connection
  Serial.print("connecting to ");
  Serial.println(SSID);

  WiFi.begin(SSID, PASSWORD);
  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.print(".");
  }

  Serial.println("");
  Serial.println("WiFi connected");
  Serial.println("IP address: ");
  Serial.println(WiFi.localIP());
  // END: Wifi connection

}

void loop() {
  //delay(100);
  WiFiClientSecure client;

  Serial.printf("Using fingerprint '%s'\n", fingerprint);
  client.setFingerprint(fingerprint);

  if (!client.connect(HOST, 443)) {
    Serial.println("connection failed");
    return;
  }

   data = "{'Temperature':25.25 , 'Deviceid':'esp3'}";
   request = String("POST ") + END_POINT + " HTTP/1.1\r\n" +
               "Host: " + HOST + "\r\n" +
               "Authorization: SharedAccessSignature " + fullSas + "\r\n" +                
               "Content-Type: application/atom+xml;type=entry;charset=utf-8\r\n" + 
               "Content-Length: " + data.length() + "\r\n\r\n" +
               data;
    Serial.println(request);
  client.print(request);
 delay(100);  
}

Ответы [ 2 ]

0 голосов
/ 09 марта 2020

Очевидно, что часть создания SAS не работает должным образом. Когда я использую сценарий python (при условии здесь ) для создания SAS, это сработало. Интересно, почему он сломался через 4 года?

0 голосов
/ 24 февраля 2020

Посмотрите на этот пост , который предоставляет PO C с использованием nodemcu и Azure Event Hub. Но, в основном, каждый запрос от вашего устройства IoT к концентратору событий должен проходить проверку подлинности, и в этом случае вам следует использовать токены Shared Access Signatures (SAS) и применять HTTPS.

...