Özellikler ve Azure Event Hubs terminolojisindeFeatures and terminology in Azure Event Hubs

Azure Event Hubs, ölçeklenebilir bir olay işleme alır ve büyük hacimli olayları ve verileri, düşük gecikme süresi ve yüksek güvenilirlikle işler hizmetidir.Azure Event Hubs is a scalable event processing service that ingests and processes large volumes of events and data, with low latency and high reliability. Bkz: Event Hubs nedir? üst düzey bir genel bakış.See What is Event Hubs? for a high-level overview.

Bu makalede yer alan bilgiler geliştirir genel bakış makalesive Event Hubs bileşenler ve özellikler hakkında teknik ve uygulama ayrıntılarını sağlar.This article builds on the information in the overview article, and provides technical and implementation details about Event Hubs components and features.

Ad AlanıNamespace

Bir Event Hubs ad alanı tarafından başvurulan bir benzersiz bir kapsam kapsayıcı sağlar. kendi tam etki alanı adı, içinde bir veya daha fazla event hubs'ı veya Kafka konularını oluşturma.An Event Hubs namespace provides a unique scoping container, referenced by its fully qualified domain name, in which you create one or more event hubs or Kafka topics.

Apache Kafka için Event HubsEvent Hubs for Apache Kafka

Bu özellik müşterilerin Event Hubs'a Kafka protokolünü kullanarak iletişim kurmasına olanak tanır bir uç nokta sağlar.This feature provides an endpoint that enables customers to talk to Event Hubs using the Kafka protocol. Bu tümleştirme, müşterilere bir Kafka uç noktası sağlar.This integration provides customers a Kafka endpoint. Bu, müşterilerin kendi Kafka kümelerini çalıştırmak için bir alternatif sunar, Event Hubs konuşabilir mevcut Kafka uygulamalarını yapılandırmak sağlar.This enables customers to configure their existing Kafka applications to talk to Event Hubs, giving an alternative to running their own Kafka clusters. Event Hubs için Apache Kafka, Kafka protokolü 1.0 ve üzeri destekler.Event Hubs for Apache Kafka supports Kafka protocol 1.0 and later.

Bu tümleştirme sayesinde Kafka kümelerini çalıştırmak veya bunları içeren Zookeeper yönetmeniz gerekmez.With this integration, you don't need to run Kafka clusters or manage them with Zookeeper. Bu ayrıca, En zorlu olay hub'ları gibi yakalama, otomatik şişme ve coğrafi olağanüstü durum kurtarma özelliklerinin bazılarını ile çalışmanıza olanak sağlar.This also allows you to work with some of the most demanding features of Event Hubs like Capture, Auto-inflate, and Geo-disaster Recovery.

Bu tümleştirme de yansıtma Oluşturucu gibi uygulamalar veya framework Kafka bağlanma gibi çalışması yalnızca yapılandırma değişikliğiyle clusterless sağlar.This integration also allows applications like Mirror Maker or framework like Kafka Connect to work clusterless with just configuration changes.

Olay yayımcılarıEvent publishers

Olay hub'ına veri gönderen herhangi bir olay üretici varlıktır veya olay yayımcısı.Any entity that sends data to an event hub is an event producer, or event publisher. Olay yayımcıları HTTPS veya AMQP 1.0 veya Kafka 1.0 ve üzeri kullanarak olayları yayımlayabilir.Event publishers can publish events using HTTPS or AMQP 1.0 or Kafka 1.0 and later. Olay yayımcıları kendilerini bir olay hub'ına tanıtmak için Paylaşılan Erişim İmzası (SAS) belirteci kullanır ve benzersiz bir kimliğe sahip olabilir ya da ortak bir SAS belirteci kullanabilir.Event publishers use a Shared Access Signature (SAS) token to identify themselves to an event hub, and can have a unique identity, or use a common SAS token.

Olay yayımlamaPublishing an event

Bir olayı AMQP 1.0, 1.0 (ve üzeri) Kafka veya HTTPS üzerinden yayımlayabilirsiniz.You can publish an event via AMQP 1.0, Kafka 1.0 (and later), or HTTPS. Event Hubs sağlar istemci kitaplıkları ve sınıfları olayları, .NET istemcilerinden bir olay hub'ına yayımlama.Event Hubs provides client libraries and classes for publishing events to an event hub from .NET clients. Diğer çalışma zamanları ve platformlar için Apache Qpid gibi herhangi bir AMQP 1.0 istemcisi kullanabilirsiniz.For other runtimes and platforms, you can use any AMQP 1.0 client, such as Apache Qpid. Olayları ayrı ayrı veya toplu olarak yayımlayabilirsiniz.You can publish events individually, or batched. Tek bir yayın (Olay verileri örneği), tek bir olay ya da toplu işlem olmasına bakılmaksızın 1 MB sınırı vardır.A single publication (event data instance) has a limit of 1 MB, regardless of whether it is a single event or a batch. Bu hata eşiği sonuçlarında daha büyük olaylar yayımlama.Publishing events larger than this threshold results in an error. Yayımcıların olay hub'ındaki bölümleri bilmemesi ve yalnızca bir bölüm anahtarı (sonraki bölümde açıklanmıştır) ya da kimliklerini SAS belirteci üzerinden belirtmeleri en iyi yöntemdir.It is a best practice for publishers to be unaware of partitions within the event hub and to only specify a partition key (introduced in the next section), or their identity via their SAS token.

AMQP veya HTTPS kullanma seçimi kullanım senaryosuna bağlıdır.The choice to use AMQP or HTTPS is specific to the usage scenario. AMQP, taşıma düzeyi güvenliği (TLS) veya SSL/TLS’ye ek olarak kalıcı bir çift yönlü yuva oluşturulmasını gerektirir.AMQP requires the establishment of a persistent bidirectional socket in addition to transport level security (TLS) or SSL/TLS. Oturum başlatılırken AMQP’nin ağ maliyetleri daha yüksektir, ancak HTTPS her istek için ek SSL yükü gerektirir.AMQP has higher network costs when initializing the session, however HTTPS requires additional SSL overhead for every request. Daha sık yayımcılar için AMQP daha yüksek performans sunar.AMQP has higher performance for frequent publishers.

Event Hubs

Event Hubs aynı bölüm anahtarı değerini paylaşan tüm olayların sırayla ve aynı bölüme iletilmesini sağlar.Event Hubs ensures that all events sharing a partition key value are delivered in order, and to the same partition. Bölüm anahtarlarının yayımcı ilkeleriyle birlikte kullanılması durumunda yayımcı kimliğinin ve bölüm anahtarı değerinin eşleşmesi gerekir.If partition keys are used with publisher policies, then the identity of the publisher and the value of the partition key must match. Aksi takdirde bir hata oluşur.Otherwise, an error occurs.

Yayımcı ilkesiPublisher policy

Event Hubs, yayımcı ilkeleri aracılığıyla olay yayımcıları üzerinde ayrıntılı denetim sağlar.Event Hubs enables granular control over event publishers through publisher policies. Yayımcı ilkeleri çok sayıda bağımsız olay yayımcısını kolaylaştırmak için tasarlanmış çalışma zamanı özellikleridir.Publisher policies are run-time features designed to facilitate large numbers of independent event publishers. Yayımcı ilkeleriyle her yayımcı, olayları aşağıdaki mekanizmayı kullanarak bir olay hub'ında yayımlarken kendi benzersiz tanımlayıcısını kullanır:With publisher policies, each publisher uses its own unique identifier when publishing events to an event hub, using the following mechanism:

//[my namespace].servicebus.windows.net/[event hub name]/publishers/[my publisher name]

Yayımcı adlarını önceden oluşturmanız gerekli değildir, ancak bunlar bağımsız yayımcı kimlikleri sağlamak amacıyla bir olayı yayımlarken kullanılan SAS belirteci ile eşleşmelidir.You don't have to create publisher names ahead of time, but they must match the SAS token used when publishing an event, in order to ensure independent publisher identities. Yayımcı ilkelerini kullanırken PartitionKey değeri yayımcı adına ayarlanır.When using publisher policies, the PartitionKey value is set to the publisher name. Bu hizmetin düzgün çalışması için bu değerlerin eşleşmesi gerekir.To work properly, these values must match.

CaptureCapture

Event Hubs yakalama otomatik olarak Event Hubs, akış verilerini yakalamanıza ve seçtiğiniz bir Blob Depolama hesabı veya bir Azure veri Gölü hizmeti hesabı için kaydetmeden olanak tanır.Event Hubs Capture enables you to automatically capture the streaming data in Event Hubs and save it to your choice of either a Blob storage account, or an Azure Data Lake Service account. Azure portalından yakalamayı etkinleştirme ve en küçük boyut ve yakalama gerçekleştirmek için zaman penceresi belirtin.You can enable Capture from the Azure portal, and specify a minimum size and time window to perform the capture. Event Hubs yakalama özelliğini kullanarak, kendi Azure Blob Depolama hesabı ve kapsayıcı ya da bunlardan biri yakalanan verileri depolamak için kullanılan Azure veri Gölü hizmeti hesabı belirtin.Using Event Hubs Capture, you specify your own Azure Blob Storage account and container, or Azure Data Lake Service account, one of which is used to store the captured data. Yakalanan veriler Apache Avro biçiminde yazılır.Captured data is written in the Apache Avro format.

BölümlerPartitions

Event Hubs her bir tüketicinin ileti akışında yalnızca belirli bir alt küme ya da bölümü okuduğu bölünmüş bir tüketici modeli aracılığıyla ileti akışı sağlar.Event Hubs provides message streaming through a partitioned consumer pattern in which each consumer only reads a specific subset, or partition, of the message stream. Bu model, olay işleme için yatay ölçek sağlar ve kuyruklar ile konularda kullanılamayan diğer akış odaklı özellikleri sunar.This pattern enables horizontal scale for event processing and provides other stream-focused features that are unavailable in queues and topics.

Bölüm bir olay hub'ında tutulan olayların sıralı dizisidir.A partition is an ordered sequence of events that is held in an event hub. Yeni olaylar geldikçe dizinin sonuna eklenir.As newer events arrive, they are added to the end of this sequence. Bölüm bir "yürütme günlüğü" olarak düşünülebilir.A partition can be thought of as a "commit log."

Event Hubs

Olay hub'ları, tüm bölümler, olay hub'ı uygulayan bir yapılandırılmış elde tutma süresi verilerini korur.Event Hubs retains data for a configured retention time that applies across all partitions in the event hub. Olayların süresi saat bazında dolar; bunları açıkça silemezsiniz.Events expire on a time basis; you cannot explicitly delete them. Bölümler birbirinden bağımsız olup kendi veri dizisini içerdiğinden genellikle farklı hızlarda büyürler.Because partitions are independent and contain their own sequence of data, they often grow at different rates.

Event Hubs

Bölüm sayısı, oluşturma sırasında belirtilir ve 2 ile 32 arasında olmalıdır.The number of partitions is specified at creation and must be between 2 and 32. Bölüm sayısı değiştirilemez; bu nedenle, bölüm sayısını ayarlarken uzun vadeli ölçeği dikkate almanız gerekir.The partition count is not changeable, so you should consider long-term scale when setting partition count. Bölümler, tüketen uygulamalarda gerekli aşağı akış paralelliğiyle ilişkili bir veri düzenleme mekanizmasıdır.Partitions are a data organization mechanism that relates to the downstream parallelism required in consuming applications. Bir olay hub'ındaki bölüm sayısı, sahip olmayı beklediğiniz eşzamanlı okuyucu sayısıyla doğrudan ilgilidir.The number of partitions in an event hub directly relates to the number of concurrent readers you expect to have. Event Hubs ekibine başvurarak bölüm sayısını 32’nin üzerine çıkarabilirsiniz.You can increase the number of partitions beyond 32 by contacting the Event Hubs team.

Oluşturma sırasında 32 olan mümkün olan en yüksek değer olarak ayarlamak isteyebilirsiniz.You may want to set it to be the highest possible value, which is 32, at the time of creation. Göndericilerin, geri kalan 31 bölümden oluşan 32 ' dan yalnızca tek bir bölüme gönderilmesi için yapılandırmadığınız müddetçe, birden fazla bölüme sahip olmanın sırayı korumadan birden çok bölüme gönderilmesine neden olacağını unutmayın.Remember that having more than one partition will result in events sent to multiple partitions without retaining the order, unless you configure senders to only send to a single partition out of the 32 leaving the remaining 31 partitions redundant. Önceki durumda, tüm 32 bölümlerdeki olayları okumanız gerekir.In the former case, you will have to read events across all 32 partitions. İkinci durumda, olay Işlemcisi ana bilgisayarında yapmanız gerekek yapılandırmadan farklı bir ek maliyet yoktur.In the latter case, there is no obvious additional cost apart from the extra configuration you have to make on Event Processor Host.

Bölümler tanımlanabilir ve doğrudan gönderilebilir olsa da doğrudan bir bölüme göndermek önerilmez.While partitions are identifiable and can be sent to directly, sending directly to a partition is not recommended. Bunun yerine, olay yayımcıları bölümünde tanıtılan daha yüksek düzey yapıları kullanabilirsiniz.Instead, you can use higher level constructs introduced in the Event publishers section.

Bölümler, olayı, kullanıcı tanımlı bir özellik paketini ve bölümdeki uzaklığı ve akış dizisindeki sayısı gibi meta verileri gövdesi içerir olay verileri dizisi ile doldurulur.Partitions are filled with a sequence of event data that contains the body of the event, a user-defined property bag, and metadata such as its offset in the partition and its number in the stream sequence.

En iyi ölçeğe ulaşmak için 1:1 üretilen iş birimi ve bölüm dengelemenize önerilir.We recommend that you balance 1:1 throughput units and partitions to achieve optimal scale. Tek bir bölümde, bir üretilen iş birimi için garantili giriş ve çıkış vardır.A single partition has a guaranteed ingress and egress of up to one throughput unit. Bir bölüm üzerinde daha yüksek aktarım hızı elde edebiliyor olsa da, performans garanti edilmez.While you may be able to achieve higher throughput on a partition, performance is not guaranteed. Bu nedenle, bir olay hub 'ındaki bölüm sayısının üretilen iş birimi sayısına eşit veya daha büyük olması önemle önerilir.This is why we strongly recommend that the number of partitions in an event hub be greater than or equal to the number of throughput units.

İhtiyaç duyduğunuz toplam üretilen iş miktarı verildiğinde, ihtiyacınız olan üretilen iş birimi sayısını ve minimum bölüm sayısını, kaç bölüm olması gerektiğini öğrenirsiniz.Given the total throughput you plan on needing, you know the number of throughput units you require and the minimum number of partitions, but how many partitions should you have? Elde etmek istediğiniz aşağı akış paralelliğini ve gelecekteki verimlilik ihtiyaçlarınızı temel alarak bölüm sayısı ' nı seçin.Choose number of partitions based on the downstream parallelism you want to achieve as well as your future throughput needs. Bir olay hub 'ında bulunan bölüm sayısı için ücret alınmaz.There is no charge for the number of partitions you have within an Event Hub.

Bölümleri ve kullanılabilirlikleri ile güvenilirlikleri arasındaki dengeleme hakkında daha fazla bilgi için, bkz: Event Hubs programlama kılavuzu ve Event Hubs’ta kullanılabilirlik ve tutarlılık makalesi.For more information about partitions and the trade-off between availability and reliability, see the Event Hubs programming guide and the Availability and consistency in Event Hubs article.

SAS belirteçleriSAS tokens

Event Hubs, ad alanında ve olay hub’ı düzeyinde kullanılabilen Paylaşılan Erişim İmzaları kullanır.Event Hubs uses Shared Access Signatures, which are available at the namespace and event hub level. SAS belirteci bir SAS anahtarından oluşturulur ve belirli bir biçimde kodlanmış bir URL’nin SHA karmasıdır.A SAS token is generated from a SAS key and is an SHA hash of a URL, encoded in a specific format. Event Hubs anahtar (ilke) ve belirtecin adını kullanarak karmayı yeniden oluşturabilir ve böylece gönderenin kimliğini doğrular.Using the name of the key (policy) and the token, Event Hubs can regenerate the hash and thus authenticate the sender. Normalde, olay yayımcıları için SAS belirteci yalnızca belirli bir olay hub'ı üzerindeki gönder ayrıcalıkları ile oluşturulur.Normally, SAS tokens for event publishers are created with only send privileges on a specific event hub. Bu SAS belirteci URL mekanizması, yayımcı ilkesinde sunulan yayımcı kimliğinin temelini oluşturur.This SAS token URL mechanism is the basis for publisher identification introduced in the publisher policy. SAS ile çalışma hakkında daha fazla bilgi için bkz. Service Bus ile Paylaşılan Erişim İmzası Kimlik Doğrulaması.For more information about working with SAS, see Shared Access Signature Authentication with Service Bus.

Olay tüketicileriEvent consumers

Bir olay hub'ından olay verilerini okuyan herhangi bir varlık olay tüketicisidir.Any entity that reads event data from an event hub is an event consumer. Tüm Event Hubs tüketicileri AMQP 1.0 oturumu üzerinden bağlanır ve olaylar, kullanılabilir olduğu anda oturum üzerinden iletilir.All Event Hubs consumers connect via the AMQP 1.0 session and events are delivered through the session as they become available. İstemcinin veri kullanılabilirliğini yoklaması gerekmez.The client does not need to poll for data availability.

Tüketici gruplarıConsumer groups

Event Hubs yayımlama/abonelik mekanizması tüketici grupları aracılığıyla etkinleştirilir.The publish/subscribe mechanism of Event Hubs is enabled through consumer groups. Tüketici grubu tüm olay hub'ının bir görünümüdür (durum, konum veya uzaklık).A consumer group is a view (state, position, or offset) of an entire event hub. Tüketici grupları birden çok tüketen uygulamayı her biri olay akışının ayrı bir görünümüne sahip olacak ve akışı kendi hızlarında ve kendi sapmalarıyla bağımsız bir şekilde okuyacak şekilde etkinleştirir.Consumer groups enable multiple consuming applications to each have a separate view of the event stream, and to read the stream independently at their own pace and with their own offsets.

Bir akış işleme mimarisinde her bir aşağı akış uygulaması bir tüketici grubuna karşılık gelir.In a stream processing architecture, each downstream application equates to a consumer group. Olay verilerini uzun süreli depolama alanına yazmak isterseniz bu depolama yazma uygulaması bir tüketici grubudur.If you want to write event data to long-term storage, then that storage writer application is a consumer group. Bundan sonra karmaşık olay işlemesi başka ve ayrı bir tüketici grubu tarafından gerçekleştirilebilir.Complex event processing can then be performed by another, separate consumer group. Bölümlere yalnızca bir tüketici grubu üzerinden erişebilirsiniz.You can only access partitions through a consumer group. Bir olay hub'ında her zaman varsayılan bir tüketici grubu vardır ve Standart katmanlı bir olay hub'ı için en fazla 20 tüketici grubu oluşturabilirsiniz.There is always a default consumer group in an event hub, and you can create up to 20 consumer groups for a Standard tier event hub.

Olabilir en fazla 5 eşzamanlı okuyucu tüketici grubu başına bir bölüme; ancak olduğunu yalnızca bir etkin alıcı tüketici grubu başına bir bölüme önerilir.There can be at most 5 concurrent readers on a partition per consumer group; however it is recommended that there is only one active receiver on a partition per consumer group. Tek bir bölüm içinde her Okuyucu tüm iletileri alır.Within a single partition, each reader receives all of the messages. Ardından aynı bölüme birden fazla okuyucuyu kapsayacak varsa, yinelenen iletileri işler.If you have multiple readers on the same partition, then you process duplicate messages. Bu Önemsiz olmayabilir, kodunuzda ele almanız gerekir.You need to handle this in your code, which may not be trivial. Ancak, bazı senaryolarda geçerli bir yaklaşım değildir.However, it's a valid approach in some scenarios.

Tüketici grubu URI kuralının örnekleri aşağıda verilmiştir:The following are examples of the consumer group URI convention:

//[my namespace].servicebus.windows.net/[event hub name]/[Consumer Group #1]
//[my namespace].servicebus.windows.net/[event hub name]/[Consumer Group #2]

Aşağıdaki şekilde Event Hubs akış işleme mimarisi gösterilmektedir:The following figure shows the Event Hubs stream processing architecture:

Event Hubs

Akış uzaklıklarıStream offsets

Uzaklık bir olayın bölüm içindeki konumudur.An offset is the position of an event within a partition. Uzaklığı istemci tarafındaki bir imleç olarak düşünebilirsiniz.You can think of an offset as a client-side cursor. Uzaklık, olayın bayt cinsinden numaralandırılmasıdır.The offset is a byte numbering of the event. Bu uzaklık, olay tüketicisinin (okuyucu) olay akışında olayları okumaya başlamak istediği bir noktayı belirtmesini sağlar.This offset enables an event consumer (reader) to specify a point in the event stream from which they want to begin reading events. Uzaklığı bir zaman damgası veya bir uzaklık değeri olarak belirtebilirsiniz.You can specify the offset as a timestamp or as an offset value. Tüketiciler, kendi uzaklık değerlerini Event Hubs hizmetinin dışında saklamaktan sorumludur.Consumers are responsible for storing their own offset values outside of the Event Hubs service. Bir bölüm içinde her olay bir uzaklık içerir.Within a partition, each event includes an offset.

Event Hubs

Denetim noktası oluşturmaCheckpointing

Denetim noktası oluşturma, okuyucuların bir bölüm olay dizisindeki konumlarını işaretledikleri veya uyguladıkları bir işlemdir.Checkpointing is a process by which readers mark or commit their position within a partition event sequence. Denetim noktası oluşturma, tüketicinin sorumluluğundadır ve bir tüketici grubunda bölüm başına temelinde gerçekleşir.Checkpointing is the responsibility of the consumer and occurs on a per-partition basis within a consumer group. Bu sorumluluk, her bir tüketici grubu için her bölüm okuyucusunun geçerli konumunu olay akışında izlemesi gerektiği ve veri akışının tamamlandığını düşündüğünde hizmeti bilgilendirebileceği anlamına gelir.This responsibility means that for each consumer group, each partition reader must keep track of its current position in the event stream, and can inform the service when it considers the data stream complete.

Bir okuyucunun bölüm bağlantısı kesilirse yeniden bağlandığında ilgili tüketici grubundaki o bölümün son okuyucusu tarafından daha önce gönderilen denetim noktasında okumaya başlar.If a reader disconnects from a partition, when it reconnects it begins reading at the checkpoint that was previously submitted by the last reader of that partition in that consumer group. Okuyucu bağlandığında okumaya başlayacağı konumu belirtmek için olay hub'ına uzaklığı geçirir.When the reader connects, it passes the offset to the event hub to specify the location at which to start reading. Bu şekilde, denetim noktası oluşturma özelliğini hem aşağı akış uygulamaları ile olayları "tamamlandı" olarak işaretlemek hem de farklı makinelerde çalışan okuyucular arasında bir yük devretme oluşması durumunda esneklik sağlamak amacıyla kullanabilirsiniz.In this way, you can use checkpointing to both mark events as "complete" by downstream applications, and to provide resiliency if a failover between readers running on different machines occurs. Bu denetim noktası oluşturma işleminden daha düşük bir uzaklık belirterek daha eski verilere geri dönülebilir.It is possible to return to older data by specifying a lower offset from this checkpointing process. Bu mekanizmayla denetim noktası oluşturma özelliği hem yük devretme esnekliği hem de olay akışı yeniden yürütmesi sağlar.Through this mechanism, checkpointing enables both failover resiliency and event stream replay.

Ortak tüketici görevleriCommon consumer tasks

Tüm Event Hubs tüketicileri bir durumu algılayan çift yönlü iletişim kanalı bir AMQP 1.0 oturumu üzerinden bağlanır.All Event Hubs consumers connect via an AMQP 1.0 session, a state-aware bidirectional communication channel. Her bölümde bölüme göre ayrılmış olayların taşınmasını kolaylaştıran bir AMQP 1.0 oturumu vardır.Each partition has an AMQP 1.0 session that facilitates the transport of events segregated by partition.

Bir bölüme bağlanmaConnect to a partition

Bölümlere doğrudan bağlanırken okuyucu bağlantılarının belirli bölümlerle koordine edilmesi için bir kiralama mekanizmasının kullanılması yaygın bir uygulamadır.When connecting to partitions, it is common practice to use a leasing mechanism to coordinate reader connections to specific partitions. Bu şekilde, bir tüketici grubundaki her bölümün yalnızca bir etkin okuyucuya sahip olması mümkündür.This way, it is possible for every partition in a consumer group to have only one active reader. Denetim noktası oluşturma, kiralama ve okuyucuları yönetme işlemleri, .NET istemcileri için EventProcessorHost sınıfı kullanılarak basitleştirilir.Checkpointing, leasing, and managing readers are simplified by using the EventProcessorHost class for .NET clients. Event Processor Host, akıllı bir tüketici aracısıdır.The Event Processor Host is an intelligent consumer agent.

Olayları okumaRead events

Belirli bir bölüm için bir AMQP 1.0 oturumu ve bağlantı açıldıktan sonra olaylar Event Hubs hizmeti tarafından AMQP 1.0 istemcisine teslim edilir.After an AMQP 1.0 session and link is opened for a specific partition, events are delivered to the AMQP 1.0 client by the Event Hubs service. Bu teslim mekanizması, HTTP GET gibi çekme tabanlı mekanizmalardan daha yüksek verimlilik ve daha düşük gecikme sağlar.This delivery mechanism enables higher throughput and lower latency than pull-based mechanisms such as HTTP GET. Olaylar istemciye gönderildiğinde her bir olay verisi örneği, olay dizisinde denetim noktası oluşturmayı kolaylaştırmak için kullanılan uzaklık ve dizi numarası gibi önemli meta veriler içerir.As events are sent to the client, each event data instance contains important metadata such as the offset and sequence number that are used to facilitate checkpointing on the event sequence.

Olay verileri:Event data:

  • UzaklıkOffset
  • Sıra numarasıSequence number
  • GövdeBody
  • Kullanıcı özellikleriUser properties
  • Sistem özellikleriSystem properties

Uzaklığın yönetilmesi sizin sorumluluğunuzdadır.It is your responsibility to manage the offset.

Sonraki adımlarNext steps

Event Hubs hakkında daha fazla bilgi için şu bağlantıları ziyaret edin:For more information about Event Hubs, visit the following links: