Вопросы по теме 'azure-durable-functions'

Только разветвление (и забытие) в долговечных функциях
У меня есть существующее приложение-функция с 2 функциями и очередью хранения. F1 запускается сообщением в теме служебной шины. Для каждого полученного сообщения F1 вычисляет несколько подзадач (T1, T2, ...), которые должны выполняться с различной...
2786 просмотров

Параллельные устойчивые функции Azure
У меня есть новая долговечная функция, заменяющая длительную веб-задачу, она работает хорошо и быстрее, чем предыдущая, но у меня проблема с параллелизмом. Я понимаю, что все действия относятся к центральному рабочему элементу Q, это означает, что...
676 просмотров

Как управлять историей выполнения для функций Azure Durable
Я разрабатываю процесс ETL, который использует для выполнения устойчивые функции (v2). Основной процесс выглядит следующим образом: Используйте действие, чтобы получить список кодов продуктов, которые нужно обработать Разветвление от основного...
852 просмотров

Суб-оркестровка Durable Functions никогда не возвращается к родительской оркестровке
У меня есть суб-оркестровка, которая включает в себя несколько действий. Одно из действий вызывается ~ 150 раз, и каждое действие помещается в список задач, затем ожидает Task.WhenAll (список). Каждая из этих задач возвращает изображение в кодировке...
455 просмотров

Невозможно привязать параметр orchestrationContext к типу DurableOrchestrationContext при использовании DurableOrchestration с функциями Azure
Я пытаюсь использовать новое расширение Durable Functions в Функциях Azure. Я установил этот пакет Nuget в свой проект Function: Microsoft.Azure.WebJobs.Extensions.DurableTask А затем использовал DurableOrchestrationContext в моей функции...
935 просмотров

Автоматическая повторная попытка функции Azure при сбое UnhandledPromiseRejectionWarning
const fetch = require('node-fetch'); let url = 'something.com'; module.exports = function(context) { let a = fetch(url) a.then(res => { if(res.status!=200) throw new Error(res.statusText) else{ context.done(null, res.body);...
327 просмотров

Долговечный триггер BLOB-объекта
Мне нужна помощь в написании устойчивой функции с триггером blob, может ли кто-нибудь помочь в этом. Я уже создал функцию запуска большого двоичного объекта, которая будет обрабатывать любой новый файл, поступающий в большой двоичный объект, теперь...
1059 просмотров

Тайм-аут в функции активности долговременных функций Azure
В своей функции деятельности я делаю это do { await timeout(500); } while (await getStatus() === false); куда, function timeout(ms) { return new Promise(resolve => setTimeout(resolve, ms)); } getStatus() - это...
2599 просмотров

Использование Task.Delay внутри действия функции Azure Durable
Можно ли использовать Task.Delay внутри действия функции Azure Durable? Я опрашиваю хранилище на предмет данных, которые должны прибыть в течение 20–30 секунд или около того. while (requestAccepted && retryCount < 8) {...
1207 просмотров

Отправка масштабируемых сообщений в служебную шину из устойчивых функций
У меня есть сценарий, в котором одна функция активности извлекает набор записей, которые могут быть от 1000 до миллиона и хранятся в объекте. Затем этот объект используется следующей функцией действия для отправки сообщений параллельно служебной...
314 просмотров

Можно ли вызывать функции активности из частных методов в оркестраторе функций Durable?
Можно ли вызывать функции активности из частных методов в оркестраторе устойчивых функций или этого следует избегать? Вот пример: [FunctionName(nameof(OrchFunc))] public async Task OrchFunc( [OrchestrationTrigger] DurableOrchestrationContext...
149 просмотров
schedule 13.06.2022

Повторная попытка действия / оркестратора Durable Function позже
Рассмотрим следующий сценарий: Мой оркестратор O запускается и вызывает суб-оркестратор S . S успешно обрабатывает действия A1 и A2 , но не выполняет A3 . У меня есть автоматические повторные попытки на A3 , но мне не повезло...
390 просмотров

Создайте подписку на служебную шину в надежных функциях
Можно ли создать подписку на служебную шину и зарегистрировать обработчик сообщений? Я новичок в надежных функциях и очень обеспокоен из-за ограничения кода оркестратора , особенно с этим: Код Orchestrator никогда не должен инициировать...
144 просмотров

Триггер активности вызывается дважды в оркестраторе
У нас есть оркестратор, который вызывается триггером таймера каждую минуту. В оркестраторе есть несколько триггеров действий, вызываемых в механизме цепочки функций. Однако был один случай, когда каждый триггер активности вызывался дважды с разницей...
575 просмотров

Очистка журнала при отладке устойчивых функций Azure
Долговечные функции сохраняют состояние в хранилище, это то, что заставляет их работать, но это очень хлопотно при отладке и разработке. У меня есть большое количество запусков, которые не были завершены, и система пытается запустить снова, когда я...
2647 просмотров

Как использовать одни и те же функции Azure с разными параметрами
У меня есть консольное приложение для синхронизации продуктов, данных заказов для разных клиентов. Я использую API для извлечения и передачи данных с одного сервера на другой с помощью планировщика задач. Но теперь я столкнулся с проблемой, так как...
160 просмотров

Как имитировать вызовы устойчивых сущностей в устойчивых функциях Azure?
Я использую MOQ для имитации надежного объекта, но вижу эту ошибку: Методы расширения (здесь: DurableContextExtensions.CallEntityAsync) нельзя использовать в выражениях настройки / проверки. Вот как я это делаю: mockContext.Setup(e...
635 просмотров

Устойчивая функция Azure: обнаружено многопоточное выполнение (с образцом кода по умолчанию)
Я создал следующее, используя предоставленный по умолчанию пример кода в Функциях Azure: HTTP-стартер с надежными функциями Оркестратор устойчивых функций Активность устойчивых функций с именем Hello1 HTTP Starter вызывает Orchestrator,...
205 просмотров

Как кэшировать данные между экземплярами оркестровки функций Azure Durable?
В документации указано, что код оркестровки функций Azure Durable должен быть детерминированным за счет повторов. В моем случае у меня есть некоторые данные в хранилище таблиц Azure, которые мне нужно получить в рабочем процессе. Рабочий процесс...
505 просмотров

Как сделать устойчивый пост-вызов в лазурной функции ServiceBusTrigger?
Привет, я использую функцию ServiceBusTrigger azure, чтобы получать сообщения, полученные в очереди, а затем отправлять их на свой веб-интерфейс, который собирается делать некоторые вещи с этим содержимым...
532 просмотров