Azure Monitor Ingestion SDK for Java Acceptance Criteria

SDK: com.azure:azure-monitor-ingestionRepository: https://github.com/Azure/azure-sdk-for-java/tree/main/sdk/monitor/azure-monitor-ingestionPurpose: Skill testing acceptance criteria for validating generated code correctness

---

1. Correct Import Patterns

1.1 Client Imports

✅ CORRECT: Ingestion Clients

import com.azure.monitor.ingestion.LogsIngestionClient;
import com.azure.monitor.ingestion.LogsIngestionClientBuilder;
import com.azure.monitor.ingestion.LogsIngestionAsyncClient;

✅ CORRECT: Authentication

import com.azure.identity.DefaultAzureCredential;
import com.azure.identity.DefaultAzureCredentialBuilder;

1.2 Model Imports

✅ CORRECT: Ingestion Models

import com.azure.monitor.ingestion.models.LogsUploadOptions;

---

2. Client Creation Patterns

2.1 ✅ CORRECT: Builder with DefaultAzureCredential

String endpoint = System.getenv("DATA_COLLECTION_ENDPOINT");

DefaultAzureCredential credential = new DefaultAzureCredentialBuilder().build();

LogsIngestionClient client = new LogsIngestionClientBuilder()
    .endpoint(endpoint)
    .credential(credential)
    .buildClient();

2.2 ✅ CORRECT: Async Client

LogsIngestionAsyncClient asyncClient = new LogsIngestionClientBuilder()
    .endpoint(endpoint)
    .credential(new DefaultAzureCredentialBuilder().build())
    .buildAsyncClient();

---

3. Upload Logs

3.1 ✅ CORRECT: Basic Upload

String ruleId = System.getenv("DATA_COLLECTION_RULE_ID");
String streamName = System.getenv("STREAM_NAME");

List<Object> logs = new ArrayList<>();
logs.add(new MyLogEntry("2024-01-15T10:30:00Z", "INFO", "Application started"));
logs.add(new MyLogEntry("2024-01-15T10:30:05Z", "DEBUG", "Processing request"));

client.upload(ruleId, streamName, logs);

3.2 ✅ CORRECT: Upload with Concurrency

LogsUploadOptions options = new LogsUploadOptions()
    .setMaxConcurrency(3);

client.upload(ruleId, streamName, logs, options, Context.NONE);

3.3 ✅ CORRECT: Upload with Error Handling

LogsUploadOptions options = new LogsUploadOptions()
    .setLogsUploadErrorConsumer(uploadError -> {
        System.err.println("Upload error: " + uploadError.getResponseException().getMessage());
        System.err.println("Failed logs count: " + uploadError.getFailedLogs().size());
    });

client.upload(ruleId, streamName, logs, options, Context.NONE);

---

4. Log Entry Model

4.1 ✅ CORRECT: Log Entry Class

public class MyLogEntry {
    private String timeGenerated;
    private String level;
    private String message;
    
    public MyLogEntry(String timeGenerated, String level, String message) {
        this.timeGenerated = timeGenerated;
        this.level = level;
        this.message = message;
    }
    
    public String getTimeGenerated() { return timeGenerated; }
    public String getLevel() { return level; }
    public String getMessage() { return message; }
}

---

5. Error Handling

5.1 ✅ CORRECT: HTTP Exception Handling

import com.azure.core.exception.HttpResponseException;

try {
    client.upload(ruleId, streamName, logs);
} catch (HttpResponseException e) {
    System.err.println("HTTP Status: " + e.getResponse().getStatusCode());
    if (e.getResponse().getStatusCode() == 403) {
        System.err.println("Check DCR permissions");
    }
}

---

6. Best Practices Checklist

• [ ] Use DefaultAzureCredential for authentication
• [ ] Use environment variables for DCE endpoint and DCR ID
• [ ] Batch logs for upload efficiency
• [ ] Use concurrency for large uploads
• [ ] Handle partial failures with error consumer
• [ ] Include TimeGenerated field in log entries
• [ ] Reuse client throughout application