Веб-задания Azure с параллелизмом заданий Entity Framework

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

Кроме того, официальная документация DbContext предлагает следующие рекомендации по управлению экземплярами DbContext в WebApps. : "При работе с веб-приложениями используйте экземпляр контекста для каждого запроса". Это руководство применимо к вашему случаю веб-задания.

Как упоминалось в моем комментарии, решение проблемы параллелизма сводится к сохранению времени жизни DbContext в пределах одного метода WebJob, поскольку EF не является потокобезопасным. Попытка использовать Unity и IJobActivator сохранила эти вещи на более высоком уровне (вне метода), и даже изменение LifetimeManager не дало никакого эффекта. Избавившись от Unity и просто создав оператор «using» внутри WebJob в DbContext, он сохранил все в безопасности и работал.

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

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

У меня есть реализация IJobActivator с использованием Simple Injector.

/// <summary>
/// An activator that uses <see cref="SimpleInjector"/> to return instance of a job type.
/// </summary>
public class SimpleInjectorJobActivator : IJobActivator
{
    /// <summary>
    /// Gets or sets the container to resolve dependencies.
    /// </summary>
    private readonly Container _container;

    /// <summary>
    /// Initialize a new instance of the <see cref="SimpleInjectorJobActivator"/> class.
    /// </summary>
    /// <param name="container">The <see cref="Container"/> to resolve dependencies.</param>
    public SimpleInjectorJobActivator(Container container)
    {
        _container = container;
    }

    /// <summary>
    /// Creates a new instance of a job type.
    /// </summary>
    /// <typeparam name="T">The job type.</typeparam>
    /// <returns>
    /// A new instance of the job type.
    /// </returns>
    public T CreateInstance<T>()
    {
        return (T)_container.GetInstance(typeof(T));
    }
}

Если вы создаете обработчик заданий для каждого триггера очереди, вы можете создать два таких класса:

public class MyJobProcessor1
{
    private readonly MyDbContext _myDbContext;

    public MyJobProcessor1(MyDbContext myDbContext)
    {
        _myDbContext = myDbContext;
    }


    public void Run([QueueTrigger("my-queue1")] BrokeredMessage message)
    {

    }
}

И моя основная функция:

static void Main()
{
    // Register my dependency, by default simple injector create a new instance per call
    var container = new Container();
    container.Register(() => new MyDbContext());
    container.Verify();

    // Configure the job host
    var config = new JobHostConfiguration
    {
        JobActivator = new SimpleInjectorJobActivator(container)
    };
    // Run the host
    var host = new JobHost(config);
    host.RunAndBlock();
}

Каждый раз, когда приходит новое сообщение, IJobActivator возвращает новый экземпляр DbContext, зарегистрированный в моем контейнере IoC.