Сообщение расписания процесса служебной шины Azure до запланированного времени

У меня есть API, который будет вызывать Azure Topic для планирования сообщения. Есть ли способ получить это сообщение до запланированного времени? Например, в приведенном ниже коде я планирую отправить сообщение в лазурную тему, и оно будет поставлено в очередь через 60 минут/1 час. Есть ли способ получить это сообщение до 1 часа?

string queueName = "topic";
var client = new ServiceBusClient("", new ServiceBusClientOptions()
{
    TransportType = ServiceBusTransportType.AmqpWebSockets
});

// create the sender
ServiceBusSender sender = client.CreateSender(queueName);

// create a message that we can send. UTF-8 encoding is used when providing a string.
ServiceBusMessage message = new ServiceBusMessage($"Hello world cancel 13 {DateTime.Now}");

// add 5 minutes delay

long seq = await sender.ScheduleMessageAsync(message,
DateTimeOffset.Now.AddMinutes(60)
);

если вы делаете это для тестирования, вы можете сделать это с помощью Service Bus Explorer или на портале Azure, отправив копию сообщения без времени расписания, а затем удалив оригинал. Это полезно только для эпизодических сценариев.

Scott Mildenberger 29.11.2022 17:14
Как установить LAMP Stack - Security 5/5 на виртуальную машину Azure Linux VM
Как установить LAMP Stack - Security 5/5 на виртуальную машину Azure Linux VM
В предыдущей статье мы завершили установку базы данных, для тех, кто не знает.
Как установить LAMP Stack 1/2 на Azure Linux VM
Как установить LAMP Stack 1/2 на Azure Linux VM
В дополнение к нашему предыдущему сообщению о намерении Azure прекратить поддержку Azure Database для MySQL в качестве единого сервера после 16...
0
1
55
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Порядковый номер сообщения, который вы получаете при планировании, подходит для отмены, но не позволяет получить это сообщение раньше. Служба не позволяет раннее получение, как и все, что получает сообщения, чтобы получать активные сообщения (не в будущем). Для этого сценария я бы предложил хранить данные в базе данных и не использовать очередь в качестве базы данных.

Другие вопросы по теме

Функция Azure выдает «Ошибка обработки сообщения (Action = Complete)» после вызова deadletrasync с автозаполнением, не установленным как False
Отправка сообщений из темы служебной шины в другую в виде пакетов с использованием IAsyncCollector в функциях Azure. Повторные попытки сохраняются даже после получения сообщения
Как создать экземпляр пространства имен служебной шины Azure для каждого разработчика с помощью Terraform и сохранить его в состоянии
Служебная шина Azure не все сообщения получены в размещенном веб-приложении службы
EventHubClient.Send: сообщение не может быть отправлено, так как оно либо получено по ссылке, либо уже отправлено по ссылке
Как записать в хранилище BLOB-объектов в качестве выходной привязки с помощью функции Azure с триггером служебной шины
Blazor Server с обменом сообщениями служебной шины Azure
Процесс заказа с устойчивыми функциями Azure или нет
Блокировка сообщений служебной шины Azure
Транзакция служебной шины в пространствах имен?

Похожие вопросы

При попытке отправить в большой двоичный объект Azure я получаю сообщение об ошибке "Версия подключения TLS не разрешена для этой учетной записи хранения"
Неавторизованная ошибка отправки сообщения из приложения-функции в сетку событий при отладке, но нормально при запуске в Azure
Работает ли Azure AzCopy между контейнерами в одной учетной записи хранения так же, как и между учетными записями хранения?
Как опубликовать сообщение на странице доски объявлений, которая просто содержит список сообщений, опубликованных пользователями ASP.NET WebForm
Вычислительные мощности Azure DataBricks ограничены 0 — почему?
Функция на основе таймера Azure, работающая одновременно
Управление жизненным циклом учетной записи хранения Azure V2 в контейнере с удалением всех больших двоичных объектов
Перечисление субъекта-службы Azure с помощью cli
Агент Azure DevOps — невозможно запустить
[Azure SDK Python]Как проверить, есть ли в подсети доступные IP-адреса?