In ASP.Net Core, ist es möglich, JSON-Ergebnisse zu streamen?

Question

Ich verwende ASP.Net Core WebAPI.

Ich habe eine Methode, die 10000 Ergebnisse aus der Datenbank zu einem Zeitpunkt abruft, aber ich stelle fest, dass es dauert 1,17 Sekunden auf "warten" und 0,3 Sekunden für die tatsächliche Übertragung (basierend auf dem Netzwerkdiagramm von Chrome).

Mit den Ergebnissen aus der Datenbank (Postgres) werden durch den DataReader iteriert und in eine Struktur konvertiert, zu einer Liste hinzugefügt und schließlich als JsonResult zurückgegeben.

Ich weiß nicht, was genau für Optionen zu erwarten, aber ich möchte in der Lage sein, so bald wie möglich zurückzukehren, um die Gesamtanforderung niedriger zu machen. Ich mache das zum ersten Mal auf dieser Plattform, also mache ich vielleicht nicht die beste Art und Weise.

[HttpGet("{turbine:int}")] 
    public IActionResult GetBearingTemperature(int turbine) 
    { 
     using (var connection = Database.GetConnection()) 
     { 
      connection.Open(); 

      int? page = GetPage(); 

      var command = connection.CreateCommand(); 

      if (page.HasValue) 
      { 
       command.CommandText = @"select turbine, timestamp, mainbearingtemperature from readings where turbine = :turbine limit 10000 offset :offset;"; 
       command.Parameters.AddWithValue("offset", NpgsqlTypes.NpgsqlDbType.Integer, page.Value * 10000); 
      } else 
      { 
       command.CommandText = @"select turbine, timestamp, mainbearingtemperature from readings where turbine = :turbine limit 10000;"; 
      } 

      command.Parameters.AddWithValue("turbine", NpgsqlTypes.NpgsqlDbType.Integer, 4, turbine);     

      var reader = command.ExecuteReader(); 

      var collection = new List<BearingTemperature>(); 

      if (reader.HasRows) 
      { 
       var bt = new BearingTemperature(); 

       while (reader.Read()) 
       {       
        bt.Time = reader.GetDateTime(1); 
        bt.Turbine = reader.GetInt32(0); 
        bt.Value = reader.GetDouble(2); 

        collection.Add(bt); 
       } 

       return new JsonResult(collection); 
      } 
      else 
      { 
       return new EmptyResult(); 
      } 

     } 
    } 

    private int? GetPage() 
    { 
     if (Request.Query.ContainsKey("page")) 
     { 
      return int.Parse(Request.Query["page"]); 
     } 
     else return null; 

    } 

    struct BearingTemperature 
    { 
     public int Turbine; 
     public DateTime Time; 
     public double Value; 
    } 

Answer 1

Bedenkt man, dass die Datenbank wird die Abfrage auszuführen und die gesamte Ergebnismenge zurückgeben, ist es nicht möglich, dass Sie eine Teil-Ergebnismenge zu streamen (obwohl Sie Streaming-Datenbank für andere Angebote google können). Stattdessen können Sie mithilfe einer mit ajax kombinierten Paging-Methode Segmente des Gesamtergebnissatzes abrufen und sie zusammen auf dem Client zusammensetzen, um die Reaktionsfähigkeit hoch zu halten und die Illusion von Streaming-Abfrageergebnissen zu erzeugen.

Sie werden OFFSET und LIMIT Klauseln aussehen wollen

Auf Ihrem api, würden Sie umfassen Parameter für Offset und Begrenzung der Client zu ermöglichen, durch zu treten und die Ergebnismenge in beliebig großen Brocken abrufen es will , Sie können damit spielen, um zu bestimmen, was gut genug reagiert. Dann benötigen Sie auf Ihrem Client eine Schleife über einen AJAX-Aufruf an Ihre API, wahrscheinlich mit jQuery, und führen eine Schleife nach der Seite durch, wobei die Ergebnisse der gebundenen Sammlung auf dem Client hinzugefügt oder ui-Elemente oder was auch immer bis zu den Ergebnissen erstellt werden komm zurück leer.

Alternativ, wenn das Anzeigen der gesamten 10k-Datensätze auf einmal nicht erforderlich ist, können Sie einfach die Ergebnisse pagen und eine Schnittstelle bereitstellen, um die Seiten zu durchlaufen. Eine, die ich für einen solchen Zweck verwendet habe, ist von Sakura auf Git Hub: PagedList