tpl-dataflow, Seitenzahl 1

TPL Dataflow (TDF) ist eine .NET-Bibliothek zum Erstellen gleichzeitiger Anwendungen. Es unterstützt Akteur / Agent-orientierte Designs durch Grundelemente für die Verarbeitung von Nachrichten, Datenfluss und Pipelining. TDF baut auf der TPL (Task Parallel Library) in .NET 4 auf und integriert sich in asynchrone Sprachunterstützung in C #, Visual Basic und F #. TDF fehlt Join / Merge nach Schlüssel (wie SSIS) und zeitbasierte Fenster (in Rx verfügbar).

Antwort

Unerwartetes Verhalten - TPL DataFlow BatchBlock Weist Elemente ab, während TriggerBatch ausgeführt wird

Wenn Sie einen Batchblock mit gebundener Kapazität erstellen und triggerBatch aufrufen, während (parallel zu) ein neuer Artikel gebucht wird, schlägt das Posten eines neuen Artikels während der Trigger-Batch-Ausführungszeit fehl. Der Aufruf d...

25.02.2016, 12:12

Antworten

Bei der asynchronen Protokollierung wird eine NullReferenceException ausgelöst

Ich versuche, einige Informationen asynchron in SQL Server innerhalb einer MVC 4-Controller-Aktion zu protokollieren, die .NET 4.0 mithilfe von AsyncTargetingPack abzielt. Ich würde direkt zu .NET 4.5 springen, aber meine App lebt in Azure und...

19.10.2012, 07:06

Antworten

Guter Ansatz für Hunderte von Benutzern und großen Dateien [geschlossen]

Ich habe mehrere Dateien (fast je 1 GB) mit Daten. Daten sind eine Zeichenfolgelinie. Ich muss jede dieser Dateien mit mehreren hundert Konsumenten verarbeiten. Jeder dieser Verbraucher führt eine Verarbeitung durch, die sich von anderen unte...

30.05.2014, 15:14

Antwort

Unterschied zwischen DataflowBlockOptions.BoundedCapacity und BufferBlockT

Nehmen wir an, ich habe eine einfache ActionBlock<int> %Vor% Ich kann eine begrenzte Kapazität angeben, um die Pufferung zu aktivieren: %Vor% Ist es besser, ein BufferBlock<T> zu erstellen und es mit dem actionBlock zu...

02.01.2014, 16:52

Antwort

tpl data flow: Fixed Puffergröße ohne Gegenstände wegwerfen

Nachdem ich mit dem Datenfluss herumgespielt habe, bin ich auf ein neues Problem gestoßen. Ich möchte die Inputqueue aller Blöcke begrenzen. Mein produzierender Block (ActionBlock) erstellt 5000 Elemente sehr schnell und postet sie in einem Broa...

17.09.2013, 09:54

Antwort

ActionBlockT anpassen

Ich möchte eine priorisierte ActionBlock<T> implementieren. So kann ich einigen TInput -Elementen bedingt Priorität geben, indem ich ein Predicate<T> verwende. Ich lese Parallel Extensions Extras Beispiele und Anleitung...

12.12.2012, 12:19

Antwort

Globale Fehlerbehandlung pro Block in einer Dataflow-Pipeline

Ich entwerfe eine lang laufende Dataflow-Pipeline, die aus mehreren Blöcken besteht. Elemente werden dem Eingabeblock der Pipeline zugeführt, gehen schließlich durch sie hindurch und werden am Ende in der Benutzeroberfläche angezeigt (aus Rücksi...

12.08.2015, 05:13

Antwort

Wie werden asynchrone Vorgänge in einem TPL Dataflow für die beste Leistung ausgeführt?

Ich habe die folgende Methode geschrieben, um eine riesige CSV-Datei stapelweise zu verarbeiten. Die Idee besteht darin, einen Teil der Zeilen aus der Datei in den Speicher einzulesen und diese Zeilen dann in Stapel fester Größe aufzuteilen. Sob...

16.08.2015, 04:19

Antworten

Umgang mit einer sehr großen Anzahl von Dateien

Ich arbeite derzeit an einem Forschungsprojekt, bei dem eine große Anzahl von Dateien indexiert wird (240k); Sie sind meist HTML, XML, doc, xls, zip, rar, pdf und Text mit Dateigrößen von ein paar KB bis zu mehr als 100 MB. Mit den extrahiert...

05.05.2012, 14:15