푸른 이벤트 허브의 청취자 배치의 최대 이벤트를 제어하고 청취자 인터페이스입니다 : 메시지에있는 항목의 최대 수를 제어 할 수있는 방법이 ProcessEventsAsync(PartitionContext context, IEnumerable<EventData> messages)
있습니까?
Azure Event Hub에서 데이터를 보내고받습니다. 요구 사항 메시지는 소비자가 순서대로 처리해야하므로 PartitionSender와 함께 가고 항상 동일한 파티션으로 이벤트를 전송하기로 결정했습니다. , 당신은 특정 파티션 당신이 보내는 어떤 경우에 사용할 수없는 것을, 당신이 오류가 발생합니다 명심해야한다 이 유형의 구성으로 : https://do
하늘 이벤트 허브 (서비스 버스의 일부)에 이벤트에 대한 전역 시퀀스 번호가 있는지 아는 사람 있습니까? EventData에서 시퀀스 번호와 오프셋을 얻을 수 있지만 그 순서는 순서대로 알 수 있습니다. 전체 이벤트 허브 (예 : 모든 파티션)에 걸쳐 시퀀스 번호가 필요합니다. 건배
Stream Analytic을 사용하여 EventHub 데이터를 SQL 데이터베이스로 저장합니다. 출력 및 출력 요청을 모두 볼 수 있지만 출력 테이블의 데이터를보기 위해 200 개의 빈 행을 볼 수 있습니다. . : 그래서이 테이블에 데이터를 전송하지만, 그냥 NULL 값 나는 문제가이 내가 쓴 방법 입력 및 출력 내 출력 테이블 :(비어 있기 때문에 사
Azure 이벤트 허브가 싱크대 인 Webhook이있는 Azure 함수가있는 예제를 설정하고 있습니다. 이 이벤트 허브에는 두 가지 다른 소비자 그룹이 있는데, 그 중 하나는 다른 Azure 기능에서 사용됩니다. 코드는 너무 멋지지 않습니다 (발췌 부분은 아래 참조). 그러나 이상한 패턴을 보았습니다. 게시 된 두 개의 메시지마다 함수를 한 번만 트리거하는
EventHostProcessor의 구현이 주어지면 동일한 프로세서 내에서 마지막 체크 포인트의 이벤트를 강제로 재생할 수 있습니까? 분명히하려면 내 파티션이 100 인치이고 10 개의 메시지를 소비했다고 가정합니다. 이 재생 방법을 호출하면 에서 이전에 소비 한 10 개의 첫 번째 메시지를 반환 할 수 있습니다. C#에서는 Stopwatch을 사용할 수
Google은 웹 API 중 하나에 대해 API 관리 포털을 설정하고 있습니다. 우리는 이벤트 로깅을 위해 이벤트 허브를 사용하고 있으며 Azure 기능을 사용하여 이벤트 메시지를 Azure Blob 저장소로 전송합니다. 메시지에 대한 응답을 제공하기 위해 API 관리 포털의 시간을 확인할 수 있습니다 (우리는 API 관리 계층에서가 아니라 백엔드 API
Microsoft.ServiceBus.Messaging.LeaseLostException 예외를주는 여러 인스턴스가있는 webjob에서 EventProcessorHost를 사용하고 있습니다. 특히 하나의 인스턴스에서만이 예외가 발생합니다. 내가 단일 인스턴스로 실행하고 때 그것은 예외를 제공하지 않습니다 Microsoft.ServiceBus.Messagin
하늘색 Eventhub에서 GetAzureEventhub 프로세서를 사용하여 데이터를 가져 오는 흐름이 있습니다. 내가 얻는 데이터는 클러스터에있는 노드 수에 의해 곱해지고 있으며, 노드가 4 개 있습니다. 기본 노드에서 실행되도록 프로세서에 지시하면 데이터가 4 번 복제되지 않습니다. 각 소비자 그룹의 eventhub는 최대 5 명의 독자를 허용하며, 나