azure相关内容
我正在尝试使用本文档中提供的REST API向Service Bus队列发送消息: https://docs.microsoft.com/en-us/rest/api/servicebus/send-message-to-queue 请注意,我不能使用Azure库来执行此任务,因为据我所知,现在没有可用的服务,并且我正在设置Python中的测试触发器以模拟将从Service Now进行的RE
..
我有一个MassTransport Saga,可以很好地处理已为其配置了Saga的Bus(Azure Service Bus)上下文中的事件、活动等。 在其中一种状态下,我需要将消息发送到另一条不同的总线(另一条Azure服务总线)。这在使用MultiBus时工作得很好。但是,在下一步中,我希望从该单独的总线接收主题消息并对其做出反应。 在MassTransport Saga中支持自动
..
我正在尝试使用服务总线队列触发器从队列中消费消息,并执行一些需要一些时间才能完成的工作。我不希望在处理消息时其他处理器拾取该消息。我在Host.json中有以下配置。当我从等待接收者的队列收到消息时。CompleteAsync(LockToken); 我收到一个异常&提供的锁无效。锁定已过期,或者该邮件已从队列中删除。"; "serviceBus": { "prefetchCo
..
我有一个相当简单的函数,可以将消息发送到Azure ServiceBus队列。 public async Task SendMessagesToQueue(string serviceBusConnectionString, int message, string queueName) { try { Queue
..
我正在使用Azure.Messaging.ServiceBus库。 我创建ServiceBusClient和ServiceBusProcessor以开始接收队列消息,如下所示: var serviceBusClient = new ServiceBusClient(connectionString); ServiceBusProcessor processor = serviceBus
..
我已尝试遵循this教程,以便根据DefaultAzureCredentials对我的服务总线进行身份验证,但是,我得到了401。 我在设置中使用了以下代码: services.AddAzureClients(x => { x.AddServiceBusClientWithNamespace("myns.servicebus.windows.net") .Wit
..
我有一个Python Azure函数,它根据主题的消息触发,它独立工作得很好。然而,如果我随后尝试将消息也写入到不同的ServiceBus队列中,它将不起作用(因为在Azure函数中,如果将新消息发布到主题,甚至不会触发)。当我包含msg_out: func.Out[str]组件时,感觉触发器条件不满足。如有任何帮助,我们将不胜感激! __init.py import logging
..
Azure Service Bus允许使用会话实体(队列和主题),我们使用它们来保持由同一使用者进行批处理(如果我们从生产者发送批处理,则它必须由同一使用者服务处理)。我找不到任何关于每个实体允许的最大会话数量的建议,我们目前有4个会话用于1000,000条消息,我想知道我们是否可以增加这个数量。如果可以,我的案例的最大可能价值是多少? 有关我的进程的简短信息: *要发送给ASB实体的1,000
..
我们在应用程序中对Azure Service Bus队列使用HTTPS模式。 ServiceBusEnvironment.SystemConnectivity.Mode = ConnectivityMode.Https; 但我们不确定Azure Service Bus如何以HTTPS模式传递消息,如果Service Bus客户端使用轮询,轮询到Azure Service Bus队列的频率
..
我需要帮助解释这些图表: 它有0个订阅。这是否意味着此主题没有内容可读? 查看邮件图表,在过去30天内,未收到或阅读此主题的邮件。 如果没有向此主题写入任何内容或从中读取任何内容,为什么会有368个传入和成功的请求? 推荐答案 这是传入请求的预期行为。 即使没有消息发送到service bus,Scale Unit(托管服务总线)始终会出于health chec
..
有没有办法创建将ServiceBusReceivedMessage的对象作为参数的azure函数?如下所示: [Function("Function1")] public static void Run( [ServiceBusTrigger("...", "...", Connection = "...")] ServiceBusReceivedMessage msg) 我为
..
我正在使用@azure/service-bus包和sendMessages函数向队列发送消息,如here中所述。 当我发送一个Java脚本数组[{ name: "Albert Einstein", "company": "xyz" }]时,它给出了一个错误TypeError: Provided value for 'message' must be of type ServiceBusMessag
..
我有一个带有Service Bus主题触发器的Azure Service Bus。我的函数如下所示 [FunctionName("SbListener")] public static async Task Run( [ServiceBusTrigger("test-topic", "test-sub-1", Connection = "Service
..
我有一个带有所有控制器的网站角度前端和后端WebAPI,我还有一个服务(C#类),我将其作为一个长期运行的任务调用以侦听传入的Azure服务总线消息。 仅供参考-我无法将任何作用域服务(DbContext)传递给单一实例(ServiceBusConsumer),因此无法将我的DB上下文传递给此服务。 问题-收到传入的Service Bus消息后,如何调用数据库并使用它? 这是我侦
..
最新的SDK(Azure.Messaging.ServiceBus 7.0.1)似乎没有向消息添加自定义(用户)属性的选项(即:用于过滤主题订阅)。现在有人知道怎么做了吗?SendMessageAsync 推荐答案 替换为ServiceBusMessage.ApplicationProperties: 在v7中,消息上的用户属性和标签被重命名为应用程序属性,并与AMQP规范保持同
..
我有一个Azure WebJob项目,我正在我的开发机器上本地运行该项目。它正在侦听Azure Service Bus消息队列。没有什么比主题更重要的了,只是最基本的消息队列。 它多次接收/处理同一邮件,在收到邮件时立即启动两次,然后在处理邮件时间歇性启动两次。 问题: 为什么我会立即多次收到相同的消息?在应用PeekLock之前似乎正在重新获取? 为什么在仍在处理中的情况下仍
..
我假设使用分区队列和主题的代价是不再保证消息排序。 由于默认情况下消息以循环方式发送到每个片段/分区,因此这将意味着不再保证消息排序。有没有人能确认是不是这样? 从分区队列接收交易时如何保证消息顺序。 支持使用分区队列/主题的FIFO消息排序的唯一方法是使用会话吗?我假设相同会话/分区键的所有消息至少都是先入先出的? 推荐答案 我在一篇博客文章中发现了这一点。 希望
..
我正在使用具有Azure Blob存储触发器的Azure Logic App。 在Azure存储中更新或修改Blob时,我从存储中提取创建或修改的Blob的内容,对数据进行一些转换,然后使用LogicApp的Create Content-Azure Blob Storage操作将其作为新的Blob内容推送回Azure存储。 随着大量Blob被插入(例如10000个文件)或更新到Blob
..
从逻辑应用程序,我正在尝试连接到Azure Blob存储并使用Path";获取Blob内容。 目标是从Blob存储中获取文件并将其附加到电子邮件中。 文件是EXCEL文件。但在该步骤中给出了以下错误。 请注意,文件名全部为小写,容器名称也为小写,不带任何字符。 但收到错误 数据-lang=“js”数据-隐藏=“假”数据-控制台=“真”数据-巴贝尔=“假”> {
..
我正在尝试使用逻辑应用程序的Azure数据湖上载文件操作将文件上载到Azure数据湖。对于大约20MB的小文件,它工作得很好。但28 MB或更大的文件失败,状态代码为413-请求实体太大。 我还在上载文件操作中启用了分块。有什么解决方案吗? 推荐答案 感谢您的回复。 我有一个变通办法。我的场景涉及从SharePoint Online获取文件并上传到Azure Data La
..