没有传入消息到事件中心

Question

无法看到来自Azure AD日志的传入消息进入Azure Event Hub。我关注了以下文章。

https://docs.microsoft.com/en-us/azure/active-directory/reports-monitoring/tutorial-azure-monitor-stream-logs-to-event-hub

有人可以让我知道我是否想念这里。

下面是图像

AAD configuration to stream logs to Event Hub

No incoming messages in Azure Event hub

Answer 1

我曾尝试使用Azure门户工具读取消息，但最终还是根据情况最终使用了DataBricks或Python。

https://docs.microsoft.com/en-us/azure/databricks/spark/latest/structured-streaming/streaming-event-hubshttps://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-python-get-started-send

非常简单（DataBricks scala示例）：

import org.apache.spark.eventhubs.{ConnectionStringBuilder, EventHubsConf, EventPosition}
import org.apache.spark.sql.functions._
import java.time.{Clock, Instant}
import java.time.temporal.ChronoUnit;
import org.apache.spark.sql._



//number of hours you want to display
val hoursToDisplay = 24




 val ehConf = EventHubsConf(yourConnectionString)
        .setStartingPosition(EventPosition.fromEnqueuedTime(Instant.now.minus(hoursToDisplay,ChronoUnit.HOURS)))
          .setConsumerGroup(yourConsumerName)




val input = spark.read.
          format("eventhubs").
          options(ehConf.toMap).
          load().
          select($"*" , $"body".cast("string").as("string_Casted_Body"))

display(input)

希望有帮助

Answer 2

似乎有一些预期的延迟。 Azure AD建议等待大约15分钟，然后再检查“事件中心”端的内容。您是否等待了足够的时间？

[大约15分钟后，请确认事件显示在事件中心中。为此，请从门户转到事件中心，并验证传入消息计数是否大于零。