将数据发布到事件中心
Posting data to the event hub
使用事件中心发现了一些我觉得很奇怪的东西。
我如何将数据发送到作为我不是设备的 eventhub。
private static Task<HttpResponseMessage> PostTelemetryAsync(string test)
{
var serviceNamespace = "dev-hub";
var hubName = "eventhub";
var url = string.Format("/{0}/publishers/testdevice/messages/", hubName);
// Create client.
var httpClient = new HttpClient
{
BaseAddress = new Uri(string.Format("https://{0}.servicebus.windows.net/", serviceNamespace))
};
var payload = JsonConvert.SerializeObject(test);
var sas = createToken("dev-hub", "anotherDevice", "IdmUSeHmcrLfjSfc2ssJVvLcsMIHM/uqG1xSLUIh5t4=");
httpClient.DefaultRequestHeaders.TryAddWithoutValidation("Authorization", sas);
var content = new StringContent(payload, Encoding.UTF8, "application/json");
content.Headers.Add("ContentType", "application/json");
return httpClient.PostAsync(url, content);
}
private static string createToken(string resourceUri, string keyName, string key)
{
TimeSpan sinceEpoch = DateTime.UtcNow - new DateTime(1970, 1, 1);
var week = 60 * 60 * 24 * 7;
var expiry = Convert.ToString((int)sinceEpoch.TotalSeconds + week);
string stringToSign = HttpUtility.UrlEncode(resourceUri) + "\n" + expiry;
HMACSHA256 hmac = new HMACSHA256(Encoding.UTF8.GetBytes(key));
var signature = Convert.ToBase64String(hmac.ComputeHash(Encoding.UTF8.GetBytes(stringToSign)));
var sasToken = String.Format(CultureInfo.InvariantCulture, "SharedAccessSignature sr={0}&sig={1}&se={2}&skn={3}", HttpUtility.UrlEncode(resourceUri), HttpUtility.UrlEncode(signature), expiry, keyName);
return sasToken;
}
在上面的代码中,我为设备 anotherDevice 生成了一个 SAS 令牌,但发布到 url ...publishers/testdevice/messages/。那是一个不同的设备。
我使用的事件处理器认为数据是从测试设备发送的,但 SAS 令牌是为另一个设备生成的。
它应该像这样工作吗?我如何使用不同设备的 SAS 令牌将数据发送到集线器,或者我在这里遗漏了什么?
授权您的应用程序发送数据的sas令牌。您可以拥有数百个不同的发布者,所有这些发布者都使用相同的 sas 令牌。将授权视为您分发给设备的共享密钥,您无需在发送前注册发布者。将令牌用作发送指标的密钥,而不是注册哪个设备发送数据的方式。
使用事件中心发现了一些我觉得很奇怪的东西。
我如何将数据发送到作为我不是设备的 eventhub。
private static Task<HttpResponseMessage> PostTelemetryAsync(string test)
{
var serviceNamespace = "dev-hub";
var hubName = "eventhub";
var url = string.Format("/{0}/publishers/testdevice/messages/", hubName);
// Create client.
var httpClient = new HttpClient
{
BaseAddress = new Uri(string.Format("https://{0}.servicebus.windows.net/", serviceNamespace))
};
var payload = JsonConvert.SerializeObject(test);
var sas = createToken("dev-hub", "anotherDevice", "IdmUSeHmcrLfjSfc2ssJVvLcsMIHM/uqG1xSLUIh5t4=");
httpClient.DefaultRequestHeaders.TryAddWithoutValidation("Authorization", sas);
var content = new StringContent(payload, Encoding.UTF8, "application/json");
content.Headers.Add("ContentType", "application/json");
return httpClient.PostAsync(url, content);
}
private static string createToken(string resourceUri, string keyName, string key)
{
TimeSpan sinceEpoch = DateTime.UtcNow - new DateTime(1970, 1, 1);
var week = 60 * 60 * 24 * 7;
var expiry = Convert.ToString((int)sinceEpoch.TotalSeconds + week);
string stringToSign = HttpUtility.UrlEncode(resourceUri) + "\n" + expiry;
HMACSHA256 hmac = new HMACSHA256(Encoding.UTF8.GetBytes(key));
var signature = Convert.ToBase64String(hmac.ComputeHash(Encoding.UTF8.GetBytes(stringToSign)));
var sasToken = String.Format(CultureInfo.InvariantCulture, "SharedAccessSignature sr={0}&sig={1}&se={2}&skn={3}", HttpUtility.UrlEncode(resourceUri), HttpUtility.UrlEncode(signature), expiry, keyName);
return sasToken;
}
在上面的代码中,我为设备 anotherDevice 生成了一个 SAS 令牌,但发布到 url ...publishers/testdevice/messages/。那是一个不同的设备。
我使用的事件处理器认为数据是从测试设备发送的,但 SAS 令牌是为另一个设备生成的。
它应该像这样工作吗?我如何使用不同设备的 SAS 令牌将数据发送到集线器,或者我在这里遗漏了什么?
授权您的应用程序发送数据的sas令牌。您可以拥有数百个不同的发布者,所有这些发布者都使用相同的 sas 令牌。将授权视为您分发给设备的共享密钥,您无需在发送前注册发布者。将令牌用作发送指标的密钥,而不是注册哪个设备发送数据的方式。