Как использовать ApplicationDbContext в потоке классов / отдельных потоков ASP.Net Core - PullRequest
Новая
       25

Как использовать ApplicationDbContext в потоке классов / отдельных потоков ASP.Net Core

0 голосов
/ 31 декабря 2018

Я пытаюсь, чтобы отдельный поток запустил цикл, чтобы собрать и импортировать данные из вызова API и вставить их в локальную базу данных.Я пытаюсь создать соединение с базой данных так же, как и в своих контроллерах, но оно продолжает выдавать различные ошибки.

Я пробовал несколько способов.Для настройки ниже это дает мне эту ошибку:

System.ObjectDisposedException: 'Невозможно получить доступ к удаленному объекту.Распространенной причиной этой ошибки является удаление контекста, который был разрешен путем внедрения зависимости, а затем попытка использовать тот же экземпляр контекста в другом месте вашего приложения.Это может произойти, если вы вызываете Dispose () для контекста или заключаете контекст в оператор using.Если вы используете внедрение зависимости, вы должны позволить контейнеру ввода зависимости позаботиться об удалении экземпляров контекста. '

Настройка предназначена для целей тестирования. 

public class HomeController : Controller
{
    public ApplicationDbContext db;

    public HomeController(ApplicationDbContext context)
    {
        db = context;
    }
    public IActionResult Index()
    {
        // This executes the code and inserts the test row no problem.
        BinanceData binanceData = new BinanceData();
        binanceData.Symbol = "Test";
        binanceData.RealTime = DateTime.Now;
        db.BinanceData.Add(binanceData);
        db.SaveChanges();
        // End

        // Where I create the new thread and start the process
        Thread doThis = new Thread(delegate ()
        {
            DataCollection dataCollection = new DataCollection(db);
            dataCollection.InsertData(DateTime.Now);
        });
        doThis.Start();
        // End

        return View();
    }

Этокласс, в котором я пытаюсь создать соединение (или передать существующее соединение) и начать цикл и собирать / вставлять данные. 

    public class DataCollection
{
    public ApplicationDbContext db;

    public DataCollection(ApplicationDbContext context)
    {
        db = context;
    }
    public void InsertData(DateTime nextTime)
    {
        List<string> tokens = new List<string> { "ETHBTC", "LTCBTC", "BNBBTC", "NEOBTC", "GASBTC", "BTCUSDT", "MCOBTC", "WTCBTC", "LRCBTC", "QTUMBTC", "YOYOBTC", "OMGBTC", "ZRXBTC", "STRATBTC", "SNGLSBTC", "BQXBTC", "KNCBTC", "FUNBTC", "SNMBTC", "IOTABTC", "LINKBTC", "XVGBTC", "SALTBTC", "MDABTC", "MTLBTC", "SUBBTC", "EOSBTC", "SNTBTC", "ETCBTC", "MTHBTC", "ENGBTC", "DNTBTC", "ZECBTC", "BNTBTC", "ASTBTC", "DASHBTC", "OAXBTC", "BTGBTC", "EVXBTC", "REQBTC", "VIBBTC", "TRXBTC", "POWRBTC", "ARKBTC", "XRPBTC", "MODBTC", "ENJBTC", "STORJBTC", "KMDBTC", "RCNBTC", "NULSBTC", "RDNBTC", "XMRBTC", "DLTBTC", "AMBBTC", "BATBTC", "BCPTBTC", "ARNBTC", "GVTBTC", "CDTBTC", "GXSBTC", "POEBTC", "QSPBTC", "BTSBTC", "XZCBTC", "LSKBTC", "TNTBTC", "FUELBTC", "MANABTC", "BCDBTC", "DGDBTC", "ADXBTC", "ADABTC", "PPTBTC", "CMTBTC", "XLMBTC", "CNDBTC", "LENDBTC", "WABIBTC", "TNBBTC", "WAVESBTC", "GTOBTC", "ICXBTC", "OSTBTC", "ELFBTC", "AIONBTC", "NEBLBTC", "BRDBTC", "EDOBTC", "WINGSBTC", "NAVBTC", "LUNBTC", "APPCBTC", "VIBEBTC", "RLCBTC", "INSBTC", "PIVXBTC", "IOSTBTC", "STEEMBTC", "NANOBTC", "VIABTC", "BLZBTC", "AEBTC", "NCASHBTC", "POABTC", "ZILBTC", "ONTBTC", "STORMBTC", "XEMBTC", "WANBTC", "WPRBTC", "QLCBTC", "SYSBTC", "GRSBTC", "CLOAKBTC", "GNTBTC", "LOOMBTC", "REPBTC", "TUSDBTC", "ZENBTC", "SKYBTC", "CVCBTC", "THETABTC", "IOTXBTC", "QKCBTC", "AGIBTC", "NXSBTC", "DATABTC", "SCBTC", "NPXSBTC", "KEYBTC", "NASBTC", "MFTBTC", "DENTBTC", "ARDRBTC", "HOTBTC", "VETBTC", "DOCKBTC", "POLYBTC", "PHXBTC", "HCBTC", "GOBTC", "PAXBTC", "RVNBTC", "DCRBTC", "USDCBTC", "MITHBTC", "BCHABCBTC" };

        foreach (string token in tokens)
        {
            BinanceData binance = new BinanceData();
            using (var client = new BinanceClient())
            {
                var data = client.GetKlines(token, Binance.Net.Objects.KlineInterval.OneMinute, null, null, 2);
                var kline = data.Data[0];
                binance.Symbol = token;
                binance.Close = kline.Close;
                binance.CloseTime = kline.CloseTime;
                binance.High = kline.High;
                binance.Low = kline.Low;
                binance.Open = kline.Open;
                binance.OpenTime = kline.OpenTime;
                binance.QuoteAssetVolume = kline.QuoteAssetVolume;
                binance.TakerBuyBaseAssetVolume = kline.TakerBuyBaseAssetVolume;
                binance.TakerBuyQuoteAssetVolume = kline.TakerBuyQuoteAssetVolume;
                binance.TradeCount = kline.TradeCount;
                binance.Volume = kline.Volume;
                binance.RealTime = DateTime.Now;
            }
        db.BinanceData.Add(binance);
        db.SaveChanges();
        }
        CountUntilNextMin(nextTime);
    }

    public void CountUntilNextMin(DateTime nextTime)
    {
        while (DateTime.Now < nextTime)
        {
            System.Threading.Thread.Sleep(10000);
        }
        DateTime passTime = DateTime.Now.AddMinutes(1);
        InsertData(passTime);
    }
}

Вот мой класс ApplicationDbContext 

    public class ApplicationDbContext : IdentityDbContext
{
    public DbSet<ApplicationUser> ApplicationUsers { get; set; }
    public DbSet<BinanceData> BinanceData { get; set; }
    public ApplicationDbContext(DbContextOptions<ApplicationDbContext> options)
        : base(options)
    {
    }

    public ApplicationDbContext()
        : base()
    {
    }
}

И мойStartUp.cs Метод ConfigureServices 

        public void ConfigureServices(IServiceCollection services)
    {
        services.Configure<CookiePolicyOptions>(options =>
        {
            // This lambda determines whether user consent for non-essential cookies is needed for a given request.
            options.CheckConsentNeeded = context => true;
            options.MinimumSameSitePolicy = SameSiteMode.None;
        });

        services.AddDbContext<ApplicationDbContext>(options =>
            options.UseSqlServer(
                Configuration.GetConnectionString("DefaultConnection")));
        services.AddIdentity<IdentityUser, IdentityRole>()
            .AddDefaultUI()
            .AddDefaultTokenProviders()
            .AddEntityFrameworkStores<ApplicationDbContext>();

        services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_1);
    }

Ответы [ 2 ]

0 голосов
/ 01 января 2019

я использую это, вызывая CreateScope, попробуйте 

public static async Task InitializeDatabaseAsync(IServiceProvider serviceProvider, IHostingEnvironment env)
{
    var result = false;

    using (var scope1 = serviceProvider.CreateScope())
    using (var db1 = scope1.ServiceProvider.GetService<MainContext>())
    {
         result = await db1.Database.EnsureCreatedAsync();
        if (result)
        {

            InsertTestData(serviceProvider, env);
        }
    }
}

затем 

using (var scope = serviceProvider.GetRequiredService<IServiceScopeFactory>().CreateScope())
using (var db = scope.ServiceProvider.GetService<MainContext>())
{
    existingData = db.Set<TEntity>().ToList();
}
0 голосов
/ 31 декабря 2018

По умолчанию ваш DI-контейнер определяет DbContext для запроса.Если вы хотите использовать один в длительном фоновом процессе, просто создайте его напрямую.Например: 

Thread doThis = new Thread(delegate ()
{
    using (var db = new ApplicationDbContext())
    {
      DataCollection dataCollection = new DataCollection();
      dataCollection.InsertData(DateTime.Now);
    }
});

Необходимо настроить DbContext, и самый простой способ сделать это - просто переопределить OnConfiguring для подключения к вашей базе данных.Минимально, как это: 

protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
{
      optionsBuilder.UseSqlServer("Server=YourServer;Database=YourDatabase;Trusted_Connection=True;MultipleActiveResultSets=true");
}

Хотя вы, вероятно, захотите прочитать строку подключения из вашей конфигурации.

...