我在一个微服务架构中工作,并在k8s中部署它们。对于不同应用程序之间的通信,我们使用Azure eventhub来发布和订阅事件。我的问题是,如果一个应用程序的多个实例( POD )正在运行,那么subscribed事件回调将在单个POD中触发还是在每个POD中触发? 是否需要将PODs划分到不同的消费群中?
我使用WebJob的绑定到EventHub,如下所述: https://github.com/Azure/azure-webjobs-sdk/wiki/EventHub-support 当webjob正在运行时,尝试运行 Azure Service Bus Explorer 在同一集线器上会导致此异常: Exception: A receiver with a higher epoch '14' already exists. A new receiver with epoch 0 cannot be created.
Make sure you are creating
我已经创建了一个Azure事件中心,现在我正在尝试添加"Listen“和"Send”共享访问策略。当我试图保存它们时,我得到了以下错误:
SubCode=40000. PartitionCount cannot be changed for EventHub.
我没有改变"Partition Count",所以我不知道为什么会出现这个错误。对于如何解决这个问题,有什么建议吗?
我有一个制作人,它将事件发送到事件中心。我想要创建两个接收器,以接收事件从连击。如何实现这一点。
接收者代码:
from azure.storage.blob import BlobServiceClient, BlobClient, ContainerClient
from azure.eventhub import EventHubSharedKeyCredential, EventData, EventHubConsumerClient
from azure.core.exceptions import ResourceExistsError
from azure.eventhub.ex
我正在试着减轻我的主服务器的负载。为此,我创建了一个微服务来处理我的打印任务,这项任务消耗了很多资源,并试图通过使用Azure事件中心将两者集成在一起。问题是,我似乎不能让网络作业工作。这是webjob的代码:
public class Functions
{
[NoAutomaticTrigger]
public static async Task StartConsumerService()
{
Trace.WriteLine("Print - Inside StartConsumerService - Before GetEventProc
我有一个IoT集线器,我正在尝试监控到来的消息,我在Visual Studio2019和VSCODE中都尝试过,右键单击内置端点的IoTHub监视器,我得到了这个错误。 [Monitor Built-in Event Endpoint Message] [30/10/2020 8:55:07] Error in monitor built-in event endpoint message: At least one receiver for the endpoint is created with epoch of '5', and so non-epoch rece
我有这样的代码:
async def run_events_listener():
# Create an Azure blob checkpoint store to store the checkpoints.
checkpoint_store = BlobCheckpointStore.from_connection_string(os.getenv('CHECKPOINT_STORE_URI'), os.getenv('CHECKPOINT_CONTAINER'))
# Create a consumer client for
我使用EventHubConsumerClient.ReadEventsAsync方法读取eventHub中的事件。当我使用默认的eventHub时,它工作得很好。但是,当我将其路由到一个新的eventHub时,我会不时地得到EventHubsExeception(ConsumerDisconnected)。从文件上看。它说,这是由于A client was forcefully disconnected from an Event Hub instance. This typically occurs when another consumer with higher OwnerLevel
我的目标是部署一个流分析,其中包含一个甚至是作为输入。要做到这一点,我需要得到shareAcessPolicyKey。经过一些搜索,我找到了ListKeys函数,但仍然不适合我的情况。
{
"error": {
"code": "ResourceNotFound",
"message": "The Resource 'Microsoft.ServiceBus/namespaces/tbiNamespace' under resource group 'devOps' wa
最新版本的Azure函数工具(版本1.0.9)在启动时生成以下警告:
ServicePointManager.DefaultConnectionLimit is set to the default value of 2.
This can limit the connection throughput to services like Azure Storage. For
more information, see https://aka.ms/webjobs-connections.
提供的链接中的信息建议在Azure WebJob的Main方法中设置此值。但是,函数没有Main方法。