使用Azure事件中心中的特定消费者组来输入事件

Question

我在事件中心有 2 个消费者组。 Synapse 使用它来推送事件，然后由 Azure 函数使用，然后 AZ 函数推送到事件中心并由逻辑应用程序使用。 Eventhub 名称：学校 - 消费者群体：学生、教师。早些时候，我有两个不同的事件中心来完成这两项工作，现在我正在使用消费者组。

我之前使用 Synapse 仅在事件中心推送我的事件，这很简单：

https://myschool-integration.servicebus.windows.net/school/messages

在这种情况下，老师需要帮助将数据推送到特定的消费者组中。

在Azure函数中，我使用此代码将数据推送到事件中心，但不确定如何将其推送到特定的消费者组。

def send_event_data_batch(json_string):
    try:
        producer = EventHubProducerClient.from_connection_string(
        conn_str=EVENT_HUB_CONNECTION_STR,
        eventhub_name=school,
        )
        with producer:
            event_data_batch = producer.create_batch()
            event_data_batch.add(EventData(json_string))
            producer.send_batch(event_data_batch)
    except:
        logging.error(f"Failed to send data to Event Hub")
        raise

我需要使用消费者组，因为现在每次事件到达 eventhub 时，它都会触发函数和逻辑应用程序。所以有2次尝试。

Answer 1

您无法将事件发布到特定的消费者组。消费者组并不是数据的物理边界，它只是一个标签，用于申请读者的逻辑分组。

事件中心中只有一个事件流，所有消费者都从中读取，无论他们标识为哪个消费者组。