إرسال بيانات السجل إلى Azure Monitor باستخدام واجهة برمجة تطبيقات HTTP Data Collector (مهملة)

توضح هذه المقالة كيفية استخدام HTTP Data Collector API لإرسال بيانات السجل إلى Azure Monitor من عميل REST API. وتصف كيفية تنسيق البيانات التي يتم جمعها بواسطة البرنامج النصي أو التطبيق الخاص بك، وتضمينها في طلب، ويكون هذا الطلب مصرحًا به من قبل Azure Monitor. نقدم أمثلة لـAzure PowerShell وC# وPython.

إشعار

تم إهمال واجهة برمجة تطبيقات Azure Monitor HTTP Data Collector ولن تعمل اعتبارا من 9/14/2026. تم استبداله بواجهة برمجة تطبيقات استيعاب السجلات.

المفاهيم

يمكنك استخدام HTTP Data Collector API لإرسال بيانات السجل إلى مساحة عمل Log Analytics في Azure Monitor من أي عميل يمكنه استدعاء REST API. قد يكون العميل runbook في Azure Automation يقوم بتجميع بيانات الإدارة من Azure أو مجموعة سحابية أخرى، أو قد يكون نظام إدارة بديلًا يستخدم Azure Monitor لدمج بيانات السجل وتحليلها.

يتم تخزين كافة البيانات في مساحة عمل Log Analytics كسجل مع نوع سجل معين. تنسيق البيانات لإرسالها إلى HTTP Data Collector API كسجلات متعددة في JavaScript Object Notation (JSON). عند إرسال البيانات، يتم إنشاء سجل فردي في المستودع لكل سجل في حمولة الطلب.

إنشاء طلب

لاستخدام HTTP Data Collector API، قم بإنشاء طلب POST يتضمن البيانات لإرسالها في JSON. تسرد الجداول الثلاثة التالية السمات المطلوبة لكل طلب. سنصف كل سمة بمزيد من التفصيل لاحقًا في المقالة.

طلب URI

السمة	الخاصية
الطريقة	POST
URI	https://<CustomerId>.ods.opinsights.azure.com/api/logs?api-version=2016-04-01
نوع المحتوى	تطبيق/json

معلمات طلب URI

المعلمة	‏‏الوصف‬
معرّف العميل	المعرف الفريد لمساحة عمل Log Analytics.
مورد	اسم مورد API: /api/logs.
إصدار API	إصدار API لاستخدامه مع هذا الطلب. حاليا، الإصدار هو 2016-04-01.

عناوين الطلبات

الرأس	‏‏الوصف
التصريح	توقيع التفويض. في وقت لاحق في المقالة، يمكنك قراءة كيفية إنشاء عنوان HMAC-SHA256.
Log-Type	حدد نوع سجل البيانات التي يتم إرسالها. يمكن أن يحتوي على أحرف وأرقام ورمز (_) فقط، ولا يمكن أن يتجاوز 100 حرف.
x-ms-date	تاريخ معالجة الطلب، بتنسيق RFC 1123 .
x-ms-AzureResourceId	معرف المورد لمورد Azure الذي يجب أن تكون البيانات مقترنة به. فإنه يملأ الخاصية _ResourceId ويسمح للبيانات بتضمينها في استعلامات سياق المورد. إذا لم يتم تحديد هذا الحقل، فلن يتم تضمين البيانات في استعلامات سياق المورد.
time-generated-field	اسم حقل في البيانات التي تحتوي على الطابع الزمني لعنصر البيانات. إذا قمت بتحديد حقل، يتم استخدام محتوياته لـTimeGenerated. إذا لم تحدد هذا الحقل، فإن الإعداد الافتراضي لـTimeGenerated هو الوقت الذي يتم فيه استيعاب الرسالة. يجب أن تتبع محتويات حقل الرسالة صيغة ISO 8601 YYYY-MM-DDThh:mm:ssZ. لا يمكن أن تكون قيمة Time Generated أقدم من يومين قبل تلقي الوقت أو أكثر من يوم في المستقبل. في مثل هذه الحالة، سيتم استخدام الوقت الذي يتم فيه استيعاب الرسالة.

التصريح

يجب أن يتضمن أي طلب إلى Azure Monitor HTTP Data Collector API عنوان التفويض. لمصادقة طلب، قم بتوقيع الطلب إما باستخدام المفتاح الأساسي أو الثانوي لمساحة العمل التي تقوم بإجراء الطلب. ثم تمرير هذا التوقيع كجزء من الطلب.

فيما يلي تنسيق عنوان التفويض:

Authorization: SharedKey <WorkspaceID>:<Signature>

WorkspaceID هو معرّف فريد لمساحة عمل Log Analytics. التوقيع هو رمز مصادقة الرسائل المستند إلى التجزئة (HMAC) الذي تم إنشاؤه من الطلب ثم تم حسابه باستخدام خوارزمية SHA256. ثم قم بترميزه باستخدام ترميز Base64.

استخدم هذا التنسيق لترميز سلسلة التوقيع SharedKey:

StringToSign = VERB + "\n" +
                  Content-Length + "\n" +
                  Content-Type + "\n" +
                  "x-ms-date:" + x-ms-date + "\n" +
                  "/api/logs";

وفيما يلي مثال لسلسلة توقيع:

POST\n1024\napplication/json\nx-ms-date:Mon, 04 Apr 2016 08:00:00 GMT\n/api/logs

عندما يكون لديك سلسلة التوقيع، قم بالترميز باستخدام خوارزمية HMAC-SHA256 على سلسلة UTF-8-encoded ثم ترميز النتيجة كـBase64. استخدم هذا التنسيق:

Signature=Base64(HMAC-SHA256(UTF8(StringToSign)))

تحتوي العينات في المقاطع التالية على نموذج تعليمات برمجية لمساعدتك في إنشاء عنوان التفويض.

نص الطلب

يجب أن يكون نص الرسالة بـJSON. يجب أن يتضمن سجلًا واحدًا أو أكثر مع اسم الخاصية وأزواج القيم بالتنسيق التالي. يمكن أن يحتوي اسم الخاصية على أحرف وأرقام وأحرف تسطير أسفل السطر (_) فقط.

[
    {
        "property 1": "value1",
        "property 2": "value2",
        "property 3": "value3",
        "property 4": "value4"
    }
]

يمكنك تجميع سجلات متعددة معًا في طلب واحد باستخدام التنسيق التالي. يجب أن تكون كافة السجلات من نفس نوع السجل.

[
    {
        "property 1": "value1",
        "property 2": "value2",
        "property 3": "value3",
        "property 4": "value4"
    },
    {
        "property 1": "value1",
        "property 2": "value2",
        "property 3": "value3",
        "property 4": "value4"
    }
]

نوع السجل وخصائصه

تعريف نوع سجل مخصص عند إرسال البيانات من خلال Azure Monitor HTTP Data Collector API. حاليًّا، لا يمكنك كتابة البيانات إلى أنواع السجلات الموجودة التي تم إنشاؤها بواسطة أنواع البيانات والحلول الأخرى. Azure Monitor يقرأ البيانات الواردة ثم ينشئ خصائص تطابق أنواع البيانات من القيم التي تقوم بإدخالها.

يجب أن يتضمن كل طلب إلى Data Collector API عنوان Log-Type مع اسم لنوع السجل. يتم إلحاق اللاحقة _CL تلقائيًّا بالاسم الذي أدخلته لتمييزه عن أنواع السجل الأخرى كسجل مخصص. على سبيل المثال، إذا قمت بإدخال اسم MyNewRecordType، يقوم Azure Monitor بإنشاء سجل بنوع MyNewRecordType_CL. يساعد هذا على التأكد من عدم وجود تعارضات بين أسماء الأنواع التي أنشأها المستخدم وتلك التي يتم شحنها في حلول Microsoft الحالية أو المستقبلية.

لتعريف نوع بيانات خاصية، يضيف Azure Monitor لاحقة إلى اسم الخاصية. إذا كانت الخاصية تحتوي على قيمة خالية، فلن يتم تضمين الخاصية في هذا السجل. يسرد هذا الجدول نوع بيانات الخاصية واللاحقة المطابقة:

نوع بيانات الخاصية	اللاحقة
السلسلة	_s
قيمة منطقية	_b
مزدوج	_d
التاريخ/الوقت	_t
GUID (مخزنة كسلسلة)	_g

إشعار

يتم إعطاء قيم السلسلة التي تظهر لتكون GUIDs الللاحقة _g وتنسيقها كـGUID، حتى إذا كانت القيمة الواردة لا تتضمن شرطات. على سبيل المثال، على حد سواء "8145d822-13a7-44ad-859c-36f31a84f6dd"و 36f31a84f6dd" و"8145d82213a744ad859c36f31a84f6dd" يتم تخزينها كـ"8145d822-13a7-44ad-859c-36f31a84f6dd". الاختلافات الوحيدة بين هذه السلسلة وسلسلة أخرى هي _g في الاسم وإدراج شرطات إذا لم يتم توفيرها في الإدخال.

يعتمد نوع البيانات الذي يستخدمه Azure Monitor لكل خاصية على ما إذا كان نوع السجل للسجل الجديد موجودًا بالفعل.

• إذا لم يكن نوع السجل موجودًا، يقوم Azure Monitor بإنشاء نموذج جديد باستخدام استنتاج نوع JSON لتحديد نوع البيانات لكل خاصية للسجل الجديد.
• إذا كان نوع السجل موجودًا، يحاول Azure Monitor إنشاء سجل جديد استنادًا إلى الخصائص الموجودة. إذا لم يتطابق نوع البيانات الخاص بخاصية في السجل الجديد ولا يمكن تحويله إلى النوع الموجود، أو إذا كان السجل يتضمن خاصية غير موجودة، يقوم Azure Monitor بإنشاء خاصية جديدة تحتوي على اللاحقة ذات الصلة.

على سبيل المثال، إدخال الإرسال التالي قد ينشئ سجلًّا بثلاث خصائص number_d وboolean_bوstring_s:

إذا كنت تريد إرسال هذا الإدخال التالي، مع تنسيق كافة القيم كسلاسل، فلن تتغير الخصائص. يمكنك تحويل القيم إلى أنواع بيانات موجودة.

ولكن، إذا قمت بإجراء هذا الإرسال التالي، سينشئ Azure Monitor خصائص جديدة boolean_d وstring_d. لا يمكنك تحويل هذه القيم.

إذا قمت بإرسال الإدخال التالي، قبل إنشاء نوع السجل، يقوم Azure Monitor بإنشاء سجل بثلاث خصائص number_s وboolean_s وstring_s. في هذا الإدخال، يتم تنسيق كل من القيم الأولية كسلسلة:

الخصائص المحجوزة

يتم حجز الخصائص التالية ولا يجب استخدامها في نوع سجل مخصص. ستتلقى رسالة خطأ إذا تضمنت حمولتك أيًّا من أسماء الخصائص التالية:

• tenant
• TimeGenerated
• مسودة بيانات

حدود البيانات

البيانات التي تم نشرها إلى Azure Monitor Data collection API تخضع لقيود معينة:

• الحد الأقصى 30 ميغابايت لكل مشاركة إلى Azure Monitor Data Collector API. هذا هو حد حجم وظيفة واحدة. إذا تجاوزت البيانات من منشور واحد 30 ميغابايت، فيجب تقسيم البيانات إلى قطع أصغر في الحجم وإرسالها بشكل متزامن.
• الحد الأقصى لقيم الحقل هو 32 كيلوبايت. إذا كانت قيمة الحقل أكبر من 32 كيلو بايت، سيتم اقتطاع البيانات.
• يوصى بحد أقصى 50 حقلًا لكل نوع. هذا هو الحد العملي من منظور قابلية الاستخدام وتجربة البحث.
• تدعم الجداول في مساحات عمل Log Analytics ما يصل إلى 500 عمود فقط (يشار إليها بالحقول في هذه المقالة).
• الحد الأقصى لأسماء الأعمدة 45 حرفًا.

إرجاع أكواد

رمز حالة HTTP 200 يعني أنه تم تلقي الطلب للمعالجة. يشير هذا إلى أن العملية انتهت بنجاح.

يتم سرد المجموعة الكاملة من رموز الحالة التي قد ترجع الخدمة في الجدول التالي:

الرمز	الحالة	رمز الخطأ	‏‏الوصف
200	موافق		تم قبول الطلب بنجاح.
400	طلب غير صالح	InactiveCustomer	تم إغلاق مساحة العمل.
400	طلب غير صالح	InvalidApiVersion	لم يتم التعرف على إصدار API الذي تم تحديده من قبل الخدمة.
400	طلب غير صالح	InvalidCustomerId	معرف مساحة العمل المحدد غير صالح.
400	طلب غير صالح	InvalidDataFormat	تم إرسال JSON غير صالح. قد يحتوي نص الاستجابة على مزيد من المعلومات حول كيفية حل الخطأ.
400	طلب غير صالح	InvalidLogType	يحتوي نوع السجل المحدد على أحرف خاصة أو أرقام.
400	طلب غير صالح	MissingApiVersion	لم يتم تحديد إصدار API.
400	طلب غير صالح	MissingContentType	لم يتم تحديد نوع المحتوى.
400	طلب غير صالح	MissingLogType	لم يتم تحديد نوع سجل القيمة المطلوب.
400	طلب غير صالح	UnsupportedContentType	لم يتم تعيين نوع المحتوى على application/json.
403	محظور	InvalidAuthorization	فشلت الخدمة في مصادقة الطلب. تحقق من صحة معرف مساحة العمل ومفتاح الاتصال.
404	غير موجود		إما أن عنوان URL المتوفر غير صحيح أو أن الطلب كبير جدًّا.
429	عدد كبير جدًا من الطلبات		تشهد الخدمة كمية كبيرة من البيانات من حسابك. الرجاء إعادة محاولة الطلب لاحقًا.
500	خطأ خادم داخلي	UnspecifiedError	واجهت الخدمة خطأ داخليًّا. الرجاء إعادة محاولة الطلب.
503	الخدمة غير متوفرة	ServiceUnavailable	الخدمة غير متوفرة حاليًّا لتلقي الطلبات. الرجاء إعادة محاولة الطلب.

بيانات الاستعلام

للاستعلام عن البيانات المرسلة من قبل Azure Monitor HTTP Data Collector API، ابحث عن سجلات يساوي نوعها قيمة LogType التي قمت بتحديدها وإلحاقها بـ_CL. على سبيل المثال، إذا كنت تستخدم MyCustomLog، فسوف ترجع كافة السجلات بـMyCustomLog_CL.

طلبات نموذج

في هذا القسم هي نماذج توضح كيفية إرسال البيانات إلى Azure Monitor HTTP Data Collector API باستخدام لغات برمجة مختلفة.

لكل عينة، تعيين المتغيرات لعنوان التفويض عن طريق القيام بما يلي:

1. في مدخل Microsoft Azure، حدد موقع مساحة عمل Log Analytics.
2. حدد Agents.
3. إلى يمين معرّف مساحة العمل، حدد أيقونة نسخ ثم قم بلصق معرّف كقيمة متغير معرف العميل.
4. إلى يمين المفتاح الأساسي، حدد أيقونة نسخ ثم قم بلصق معرّف كقيمة متغير المفتاح المشترك.

بدلًا من ذلك، يمكنك تغيير المتغيرات لنوع السجل وبيانات JSON.

PowerShell

# Replace with your Workspace ID
$CustomerId = "xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx"  

# Replace with your Primary Key
$SharedKey = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"

# Specify the name of the record type that you'll be creating
$LogType = "MyRecordType"

# Optional name of a field that includes the timestamp for the data. If the time field is not specified, Azure Monitor assumes the time is the message ingestion time
$TimeStampField = ""


# Create two records with the same set of properties to create
$json = @"
[{  "StringValue": "MyString1",
    "NumberValue": 42,
    "BooleanValue": true,
    "DateValue": "2019-09-12T20:00:00.625Z",
    "GUIDValue": "9909ED01-A74C-4874-8ABF-D2678E3AE23D"
},
{   "StringValue": "MyString2",
    "NumberValue": 43,
    "BooleanValue": false,
    "DateValue": "2019-09-12T20:00:00.625Z",
    "GUIDValue": "8809ED01-A74C-4874-8ABF-D2678E3AE23D"
}]
"@

# Create the function to create the authorization signature
Function Build-Signature ($customerId, $sharedKey, $date, $contentLength, $method, $contentType, $resource)
{
    $xHeaders = "x-ms-date:" + $date
    $stringToHash = $method + "`n" + $contentLength + "`n" + $contentType + "`n" + $xHeaders + "`n" + $resource

    $bytesToHash = [Text.Encoding]::UTF8.GetBytes($stringToHash)
    $keyBytes = [Convert]::FromBase64String($sharedKey)

    $sha256 = New-Object System.Security.Cryptography.HMACSHA256
    $sha256.Key = $keyBytes
    $calculatedHash = $sha256.ComputeHash($bytesToHash)
    $encodedHash = [Convert]::ToBase64String($calculatedHash)
    $authorization = 'SharedKey {0}:{1}' -f $customerId,$encodedHash
    return $authorization
}

# Create the function to create and post the request
Function Post-LogAnalyticsData($customerId, $sharedKey, $body, $logType)
{
    $method = "POST"
    $contentType = "application/json"
    $resource = "/api/logs"
    $rfc1123date = [DateTime]::UtcNow.ToString("r")
    $contentLength = $body.Length
    $signature = Build-Signature `
        -customerId $customerId `
        -sharedKey $sharedKey `
        -date $rfc1123date `
        -contentLength $contentLength `
        -method $method `
        -contentType $contentType `
        -resource $resource
    $uri = "https://" + $customerId + ".ods.opinsights.azure.com" + $resource + "?api-version=2016-04-01"

    $headers = @{
        "Authorization" = $signature;
        "Log-Type" = $logType;
        "x-ms-date" = $rfc1123date;
        "time-generated-field" = $TimeStampField;
    }

    $response = Invoke-WebRequest -Uri $uri -Method $method -ContentType $contentType -Headers $headers -Body $body -UseBasicParsing
    return $response.StatusCode

}

# Submit the data to the API endpoint
Post-LogAnalyticsData -customerId $customerId -sharedKey $sharedKey -body ([System.Text.Encoding]::UTF8.GetBytes($json)) -logType $logType  

C#‎

using System;
using System.Net;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Security.Cryptography;
using System.Text;
using System.Threading.Tasks;

namespace OIAPIExample
{
	class ApiExample
	{
		// An example JSON object, with key/value pairs
		static string json = @"[{""DemoField1"":""DemoValue1"",""DemoField2"":""DemoValue2""},{""DemoField3"":""DemoValue3"",""DemoField4"":""DemoValue4""}]";

		// Update customerId to your Log Analytics workspace ID
		static string customerId = "xxxxxxxx-xxx-xxx-xxx-xxxxxxxxxxxx";

		// For sharedKey, use either the primary or the secondary Connected Sources client authentication key   
		static string sharedKey = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxx";

		// LogName is name of the event type that is being submitted to Azure Monitor
		static string LogName = "DemoExample";

		// You can use an optional field to specify the timestamp from the data. If the time field is not specified, Azure Monitor assumes the time is the message ingestion time
		static string TimeStampField = "";

		static void Main()
		{
			// Create a hash for the API signature
			var datestring = DateTime.UtcNow.ToString("r");
			var jsonBytes = Encoding.UTF8.GetBytes(json);
			string stringToHash = "POST\n" + jsonBytes.Length + "\napplication/json\n" + "x-ms-date:" + datestring + "\n/api/logs";
			string hashedString = BuildSignature(stringToHash, sharedKey);
			string signature = "SharedKey " + customerId + ":" + hashedString;

			PostData(signature, datestring, json);
		}

		// Build the API signature
		public static string BuildSignature(string message, string secret)
		{
			var encoding = new System.Text.ASCIIEncoding();
			byte[] keyByte = Convert.FromBase64String(secret);
			byte[] messageBytes = encoding.GetBytes(message);
			using (var hmacsha256 = new HMACSHA256(keyByte))
			{
				byte[] hash = hmacsha256.ComputeHash(messageBytes);
				return Convert.ToBase64String(hash);
			}
		}

		// Send a request to the POST API endpoint
		public static void PostData(string signature, string date, string json)
		{
			try
			{
				string url = "https://" + customerId + ".ods.opinsights.azure.com/api/logs?api-version=2016-04-01";

				System.Net.Http.HttpClient client = new System.Net.Http.HttpClient();
				client.DefaultRequestHeaders.Add("Accept", "application/json");
				client.DefaultRequestHeaders.Add("Log-Type", LogName);
				client.DefaultRequestHeaders.Add("Authorization", signature);
				client.DefaultRequestHeaders.Add("x-ms-date", date);
				client.DefaultRequestHeaders.Add("time-generated-field", TimeStampField);

				// If charset=utf-8 is part of the content-type header, the API call may return forbidden.
				System.Net.Http.HttpContent httpContent = new StringContent(json, Encoding.UTF8);
				httpContent.Headers.ContentType = new MediaTypeHeaderValue("application/json");
				Task<System.Net.Http.HttpResponseMessage> response = client.PostAsync(new Uri(url), httpContent);

				System.Net.Http.HttpContent responseContent = response.Result.Content;
				string result = responseContent.ReadAsStringAsync().Result;
				Console.WriteLine("Return Result: " + result);
			}
			catch (Exception excep)
			{
				Console.WriteLine("API Post Exception: " + excep.Message);
			}
		}
	}
}

Python

إشعار

إذا كنت تستخدم Python 2، فقد تحتاج إلى تغيير السطر: bytes_to_hash = bytes(string_to_hash, encoding="utf-8") إلى bytes_to_hash = bytes(string_to_hash).encode("utf-8")

import json
import requests
import datetime
import hashlib
import hmac
import base64

# Update the customer ID to your Log Analytics workspace ID
customer_id = 'xxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx'

# For the shared key, use either the primary or the secondary Connected Sources client authentication key   
shared_key = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"

# The log type is the name of the event that is being submitted
log_type = 'WebMonitorTest'

# An example JSON web monitor object
json_data = [{
   "slot_ID": 12345,
    "ID": "5cdad72f-c848-4df0-8aaa-ffe033e75d57",
    "availability_Value": 100,
    "performance_Value": 6.954,
    "measurement_Name": "last_one_hour",
    "duration": 3600,
    "warning_Threshold": 0,
    "critical_Threshold": 0,
    "IsActive": "true"
},
{   
    "slot_ID": 67890,
    "ID": "b6bee458-fb65-492e-996d-61c4d7fbb942",
    "availability_Value": 100,
    "performance_Value": 3.379,
    "measurement_Name": "last_one_hour",
    "duration": 3600,
    "warning_Threshold": 0,
    "critical_Threshold": 0,
    "IsActive": "false"
}]
body = json.dumps(json_data)

#####################
######Functions######  
#####################

# Build the API signature
def build_signature(customer_id, shared_key, date, content_length, method, content_type, resource):
    x_headers = 'x-ms-date:' + date
    string_to_hash = method + "\n" + str(content_length) + "\n" + content_type + "\n" + x_headers + "\n" + resource
    bytes_to_hash = bytes(string_to_hash, encoding="utf-8")  
    decoded_key = base64.b64decode(shared_key)
    encoded_hash = base64.b64encode(hmac.new(decoded_key, bytes_to_hash, digestmod=hashlib.sha256).digest()).decode()
    authorization = "SharedKey {}:{}".format(customer_id,encoded_hash)
    return authorization

# Build and send a request to the POST API
def post_data(customer_id, shared_key, body, log_type):
    method = 'POST'
    content_type = 'application/json'
    resource = '/api/logs'
    rfc1123date = datetime.datetime.utcnow().strftime('%a, %d %b %Y %H:%M:%S GMT')
    content_length = len(body)
    signature = build_signature(customer_id, shared_key, rfc1123date, content_length, method, content_type, resource)
    uri = 'https://' + customer_id + '.ods.opinsights.azure.com' + resource + '?api-version=2016-04-01'

    headers = {
        'content-type': content_type,
        'Authorization': signature,
        'Log-Type': log_type,
        'x-ms-date': rfc1123date
    }

    response = requests.post(uri,data=body, headers=headers)
    if (response.status_code >= 200 and response.status_code <= 299):
        print('Accepted')
    else:
        print("Response code: {}".format(response.status_code))

post_data(customer_id, shared_key, body, log_type)

Java

import org.apache.http.HttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.springframework.http.MediaType;

import javax.crypto.Mac;
import javax.crypto.spec.SecretKeySpec;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;
import java.text.SimpleDateFormat;
import java.util.Base64;
import java.util.Calendar;
import java.util.TimeZone;
import java.util.Locale;

import static org.springframework.http.HttpHeaders.CONTENT_TYPE;

public class ApiExample {

  private static final String workspaceId = "xxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx";
  private static final String sharedKey = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxx";
  private static final String logName = "DemoExample";
  /*
  You can use an optional field to specify the timestamp from the data. If the time field is not specified,
  Azure Monitor assumes the time is the message ingestion time
   */
  private static final String timestamp = "";
  private static final String json = "{\"name\": \"test\",\n" + "  \"id\": 1\n" + "}";
  private static final String RFC_1123_DATE = "EEE, dd MMM yyyy HH:mm:ss z";

  public static void main(String[] args) throws IOException, NoSuchAlgorithmException, InvalidKeyException {
    String dateString = getServerTime();
    String httpMethod = "POST";
    String contentType = "application/json";
    String xmsDate = "x-ms-date:" + dateString;
    String resource = "/api/logs";
    String stringToHash = String
        .join("\n", httpMethod, String.valueOf(json.getBytes(StandardCharsets.UTF_8).length), contentType,
            xmsDate , resource);
    String hashedString = getHMAC256(stringToHash, sharedKey);
    String signature = "SharedKey " + workspaceId + ":" + hashedString;

    postData(signature, dateString, json);
  }

  private static String getServerTime() {
    Calendar calendar = Calendar.getInstance();
    SimpleDateFormat dateFormat = new SimpleDateFormat(RFC_1123_DATE, Locale.US);
    dateFormat.setTimeZone(TimeZone.getTimeZone("GMT"));
    return dateFormat.format(calendar.getTime());
  }

  private static void postData(String signature, String dateString, String json) throws IOException {
    String url = "https://" + workspaceId + ".ods.opinsights.azure.com/api/logs?api-version=2016-04-01";
    HttpPost httpPost = new HttpPost(url);
    httpPost.setHeader("Authorization", signature);
    httpPost.setHeader(CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE);
    httpPost.setHeader("Log-Type", logName);
    httpPost.setHeader("x-ms-date", dateString);
    httpPost.setHeader("time-generated-field", timestamp);
    httpPost.setEntity(new StringEntity(json));
    try(CloseableHttpClient httpClient = HttpClients.createDefault()){
      HttpResponse response = httpClient.execute(httpPost);
      int statusCode = response.getStatusLine().getStatusCode();
      System.out.println("Status code: " + statusCode);
    }
  }

  private static String getHMAC256(String input, String key) throws InvalidKeyException, NoSuchAlgorithmException {
    String hash;
    Mac sha256HMAC = Mac.getInstance("HmacSHA256");
    Base64.Decoder decoder = Base64.getDecoder();
    SecretKeySpec secretKey = new SecretKeySpec(decoder.decode(key.getBytes(StandardCharsets.UTF_8)), "HmacSHA256");
    sha256HMAC.init(secretKey);
    Base64.Encoder encoder = Base64.getEncoder();
    hash = new String(encoder.encode(sha256HMAC.doFinal(input.getBytes(StandardCharsets.UTF_8))));
    return hash;
  }

}

البدائل والاعتبارات

على الرغم من أن Data Collector API يجب أن تغطي معظم احتياجاتك كما يمكنك جمع بيانات النموذج الحر في Azure Logs، قد تحتاج إلى طريقة بديلة للتغلب على بعض قيود API. يتم سرد الخيارات الخاصة بك، بما في ذلك الاعتبارات الرئيسية، في الجدول التالي:

البديل	‏‏الوصف	الأنسب لـ
الأحداث المخصصة: الاستيعاب الأصلي المستند إلى SDK في Application Insights	Application Insights، عادة ما يكون أداة من خلال SDK داخل التطبيق الخاص بك، يمنحك القدرة على إرسال بيانات مخصصة من خلال الأحداث المخصصة.	البيانات التي يتم إنشاؤها داخل التطبيق الخاص بك، ولكن لا يتم التقاطها بواسطة SDK من خلال أحد أنواع البيانات الافتراضية (الطلبات، التبعيات، الاستثناءات، وما إلى ذلك). البيانات التي غالبًا ما ترتبط ببيانات التطبيقات الأخرى في Application Insights.
Data Collector API في سجلات Azure Monitor	Data Collector API في سجلات Azure Monitor طريقة مفتوحة تمامًا لاستيعاب البيانات. يمكن إرسال أي بيانات منسقة في كائن JSON إلى هنا. بعد إرسالها، تتم معالجتها وإتاحتها في Monitor Logs ليتم ربطها ببيانات أخرى في Monitor Logs أو مقابل بيانات Application Insights الأخرى. من السهل إلى حد ما تحميل البيانات كملفات إلى النقطة تخزين Azure Blob، حيث ستتم معالجة الملفات ثم تحميلها إلى Log Analytics. للحصول على نموذج تطبيق، راجع إنشاء بنية أساسية لربط البيانات مع Data Collector API.	البيانات التي لا يتم إنشاؤها بالضرورة داخل تطبيق يتم استخدامها في Application Insights. وتشمل الأمثلة على ذلك البحث وجداول الحقائق والبيانات المرجعية والإحصاءات المجمعة مسبقًا وما إلى ذلك. البيانات التي سيتم الرجوع إليها مقابل بيانات Azure Monitor الأخرى (Application Insights، وأنواع بيانات سجلات المراقبة الأخرى، و Defender for Cloud، وContainer insights والأجهزة الظاهرية، وما إلى ذلك).
Azure Data Explorer	Azure Data Explorer، المتوفر الآن بشكل عام للجمهور، هو نظام البيانات الأساسي الذي يعمل على تشغيل Application Insights Analytics وAzure Monitor Logs. باستخدام النظام الأساسي للبيانات في شكله الخام، لديك مرونة كاملة (ولكن تتطلب الحمل من الإدارة) عبر نظام مجموعة (Kubernetes التحكم في الوصول القائم على الدور (RBAC)، معدل الاحتفاظ، المخطط، وما إلى ذلك). يوفر Azure Data Explorer العديد من خيارات الاستيعاب، بما في ذلك ملفات CSV وTSV وJSON.	البيانات التي لن يتم ربطها بأي بيانات أخرى ضمن Application Insights أو Monitor Logs. البيانات التي تتطلب إمكانيات متقدمة للاستيعاب أو المعالجة غير المتوفرة اليوم في Azure Monitor Logs.

الخطوات التالية

• استخدم Log Search API لاسترداد البيانات من مساحة عمل Log Analytics.

• تعرف على المزيد حول كيفية إنشاء خط بيانات باستخدام Data Collector API باستخدام سير عمل Logic Apps إلى Azure Monitor.