Udostępnij za pośrednictwem


Zadanie przepływ danych

Zadanie przepływ danych hermetyzuje aparat przepływ danych przenosi dane między źródła i miejsca docelowe i umożliwia użytkownikowi transformacji, należy czyścić i zmodyfikować dane, jest przenoszony.Dodatek zadanie przepływ danych do formantu pakiet przepływu umożliwia pakietu do wyodrębniania, przekształcania i ładowania danych.

Przepływ danych składa się z co najmniej jeden składnik przepływu danych, ale zwykle jest to zbiór połączonych składnik przepływu danych s: źródła, które wyodrębnić danych; przekształcenia, modyfikowanie, marszruty lub podsumowywać dane; i miejsc docelowych ładowania danych. Składniki są połączone w przepływ danych przez ścieżki.Każda ścieżka Określa dwa składniki, które są na początku i na końcu ścieżki.Aby uzyskać więcej informacji zobaczData Flow Elements.

Przy uruchomieniu czas zadanie przepływ danych tworzy plan wykonania ze strumienia danych i aparat przepływ danych jest wykonywany w planie.Można utworzyć zadanie przepływ danych ma ma przepływ danych, ale zadanie wykonywane tylko wtedy, gdy zawiera ona przepływ danych co najmniej jeden.

Następujący diagram ilustruje zadanie przepływ danych z przepływ danych w jeden.

Data flow

A zadanie przepływu danych może zawierać wiele przepływów danych.Jeśli zadanie kopiuje kilku zestawów danych, a kolejność, w którym dane są kopiowane nie ma znaczenia, może być wygodniejszy dołączyć wiele przepływów danych zadanie przepływ danych.Na przykład można utworzyć przepływy danych pięciu każdego kopiowania danych z płaskim pliku do tabela inny wymiar w schemat gwiazdy magazyn danych.

Jednak aparat przepływ danych określa kolejność wykonywania, gdy istnieje wiele przepływów danych w ramach jednej zadanie przepływ danych.W związku z tym gdy ważna jest kolejność, pakiet powinien używać wielu zadań przepływu danych, każde zadanie, zawierające jeden przepływ danych.Można następnie zastosować ograniczenia pierwszeństwo kontrolować kolejność wykonywania zadań.

Następujący diagram ilustruje zadanie przepływu danych ma wiele przepływów danych.

Data flows

Pakiet może zawierać wiele zadań przepływ danych i często wykonywać złożone pakietów.Na przykład, jeśli pakiet wymaga uruchomienie przepływy danych w określonej kolejności lub wykonywać inne zadania między przepływów danych, należy użyć oddzielne zadanie przepływ danych dla każdego przepływ danych.

zadanie przepływ danych Zarządza także przepływów błąd.Przy uruchomieniu czas, błędów poziom wiersza może występować wówczas, gdy przepływ danych konwersji składników, wyszukiwania lub ocenić wyrażeń.Na przykład kolumna danych z ciąg znaków nie można przekonwertować na liczbę całkowitą z zakresu lub wyrażenie podejmuje próbę dzielenia przez zero.Obie operacje powodują wystąpienie błędów, a wiersze zawierające błędy mogą być przetwarzane osobno przy użyciu przepływ błąd.Aby uzyskać więcej informacji dotyczących sposobów korzystania z przepływów błąd przepływ danych pakiet zobacz Obsługa błędów w danych.

Zbiorcza wstawiania danych z plików tekstowych w SQL Server Baza danych, można użyć zadania Wstaw zbiorczej zamiast zadanie przepływ danych i przepływ danych. Wstaw zbiorcze zadań nie może jednak przekształcania danych.Aby uzyskać więcej informacji zobaczZbiorcza Wstaw zadania.

Przy użyciu wyrażenia właściwość z elementami przepływ danych

Numer danych przepływ składników — źródeł, transformacje i miejsc docelowych — obsługuje korzystanie z wyrażeń właściwość w niektórych ich właściwość.Wyrażenie właściwość jest wyrażenie, które zastępuje wartość właściwość po załadowaniu do pakiet.W czasie wykonywania pakiet używane są wartości zaktualizowane właściwość.wyrażenie są zbudowane przy użyciu Integration Services Składnia wyrażenie i mogą zawierać Integration Services funkcji, operatorów, identyfikatorów i zmiennych. Aby uzyskać więcej informacji zobacz Integracja usług wyrażenie odwołania, Za pomocą wyrażenia w pakietach, a Za pomocą wyrażenia właściwość w pakietach.

Jeśli skonstruować pakiet w Business Intelligence Development Studio, właściwości składników przepływ danych obsługujących właściwość wyrażenia są narażone na zadanie przepływ danych do których należą. Aby dodać, zmienić i usunąć wyrażenia właściwości składników przepływ danych, kliknij przycisk zadanie przepływ danych, a następnie użyj okna właściwości lub edytora dla tego zadania, aby dodać, zmienić lub usunąć właściwość wyrażeń.Właściwość wyrażenia dla zadanie przepływ danych odbywa się w oknie dialogowym właściwości.

Jeśli przepływ danych zawiera jakiekolwiek składniki, należy użyć wyrażenia, wyrażenia również są dostępne w oknie dialogowym właściwości.Aby wyświetlić wyrażeń, należy wybrać zadanie przepływ danych, do którego należy komponent.Można wyświetlić właściwości, według kategorii lub w kolejności alfabetycznej.Jeśli używasz widoku skategoryzowane w oknie dialogowym właściwość wszelkimi wyrażeniami, które nie są używane w konkretnej właściwość są wyświetlane w Różne kategorii.Jeśli używasz widoku alfabetycznej wyrażenia są wymienione na liście w kolejności z nazwą składnika przepływ danych.

Wpisy dziennika

Integration Services provides a set of log events that are available to all tasks.Integration Services also provides custom log entries to many tasks.Aby uzyskać więcej informacji zobacz Wykonania rejestrowania w pakietach i Niestandardowe komunikaty o rejestrowania. Zadanie przepływ danych zawiera następujące wpisy dziennika niestandardowego:

Wpis dziennika

Description

BufferSizeTuning

Wskazuje, że zadanie przepływ danych zmieniony rozmiar buforu.Wpis dziennika w tym artykule opisano przyczyny zmiany rozmiaru i list tymczasowe nowy rozmiar buforu.

OnPipelinePostEndOfRowset

Oznacza, że składnik nadano jej sygnału koniec z zestaw wierszy, jest ustawiany przez ostatnie wywołanie ProcessInput Metoda. Wpis jest zapisywane dla każdego składnika w przepływ danych, który przetwarza dane wejściowe.Wpis zawiera nazwę składnika.

OnPipelinePostPrimeOutput

Określa, że składnik zakończyło się jego ostatniego wywołania, aby PrimeOutput Metoda. W zależności od przepływ danych można zapisać wiele wpisów dziennika.Składnik jest źródłem, tego wpisu dziennika oznacza, że składnik zakończył przetwarzanie wierszy.

OnPipelinePreEndOfRowset

Wskazuje, że składnik jest do odbioru sygnału koniec z zestaw wierszy, które jest ustawiane przez ostatnie wywołanie ProcessInput Metoda. Wpis jest zapisywane dla każdego składnika w przepływ danych, który przetwarza dane wejściowe.Wpis zawiera nazwę składnika.

OnPipelinePrePrimeOutput

Wskazuje, że składnik ma około jego telefonicznie z PrimeOutput Metoda. W zależności od przepływ danych można zapisać wiele wpisów dziennika.

OnPipelineRowsSent

Liczba wierszy, pod warunkiem że wejściowe składnika przez wywołanie do raportów ProcessInput Metoda. Wpis dziennika składa się z nazwy składnika.

PipelineBufferLeak

Zawiera informacje dotyczące każdego składnika, który będzie przechowywany buforów aktywności po Menedżera buforu wykracza poza biurem.Jeśli bufor jest nadal aktywna, bufory zasoby nie zostały wydane i może spowodować, że przecieki pamięci.Wpis dziennika zawiera nazwę składnika i identyfikator buforu.

PipelineComponentTime

Raporty ilości czas (w milisekundach), w którym składnik zużyte w każdym z jego pięć kroków przetwarzania główne — sprawdzanie poprawności, PreExecute, PostExecute, ProcessInput i ProcessOutput.

PipelineExecutionPlan

Raporty plan wykonania przepływ danych.Plan wykonania zawiera informacje dotyczące sposobu buforów zostaną wysłane do składników.Te informacje, w połączeniu z wpisu dziennika PipelineExecutionTrees opisuje, co się dzieje w ramach zadanie przepływ danych.

PipelineExecutionTrees

Raporty drzew wykonanie układ przepływ danych.Harmonogram aparatu przepływ danych używa drzew do tworzenia planu wykonania przepływ danych.

PipelineInitialization

Inicjowanie informacje o zadaniu.Informacje te obejmują katalogów do tymczasowego przechowywania danych BLOB, domyślny rozmiar buforu i liczbę wierszy w buforze.W zależności od konfiguracja zadań przepływ danych można zapisać wiele wpisów dziennika.

Te wpisy dziennika zawierają wiele informacji dotyczących wykonywania przepływ danych zadania każdego czas uruchomić pakiet.Jak pakiety zostanie uruchomione wielokrotnie, można przechwycić informacje, które znajdują się ważne informacje historyczne o przetwarzania, które wykonuje zadania, problemy, które mogą mieć wpływ na wydajność i wolumin danych, który zadań dojść w czasie.

Aby uzyskać więcej informacji na temat korzystania z tych wpisów dziennika do monitorowania i zwiększania wydajności przepływ danych zobacz jeden z następujących tematów:

Przykładowe wiadomości Z zadanie przepływu danych

Poniższa lista zawiera komunikaty przykładowe wpisy dziennika dla bardzo prostych pakiet.Pakiet używa urządzenie źródłowe danych OLE DB w celu wyodrębnienia danych z tabela transformacja sortowanie do sortowania danych, a OLE DB obiekt docelowy do zapisuje dane do innej tabela.

Wpis dziennika

Wiadomości

BufferSizeTuning

Wiersze buforu typu 0 spowodowałoby większy niż skonfigurowany maksymalny rozmiar buforu.Zostaną tylko wiersze 9637 w buforach tego typu.

Wiersze buforu typu 2 spowodowałoby większy niż skonfigurowany maksymalny rozmiar buforu.Zostaną tylko wiersze 9497 w buforach tego typu.

Wiersze buforu typu 3 spowodowałoby większy niż skonfigurowany maksymalny rozmiar buforu.Zostaną tylko wiersze 9497 w buforach tego typu.

OnPipelinePostEndOfRowset

Składnik będzie miał koniec zestawu zestaw wierszy sygnału.: 1180: Sortowania: 1181 : Wprowadzania do sortowania

Składnik będzie miał koniec zestawu zestaw wierszy sygnału.: 1291: obiekt obiekt docelowy OLE DB: 1304 : Wejście obiekt docelowy DB OLE

OnPipelinePostPrimeOutput

Składnik zwrócił z jego PrimeOutput wywołania.: 1180: Sortowanie

Składnik zwrócił z jego PrimeOutput wywołania.: 1: urządzenie źródłowe DB OLE

OnPipelinePreEndOfRowset

Składnik zakończył przetwarzanie wszystkich swoich wierszy.: 1180: Sortowania: 1181 : Wprowadzania do sortowania

Składnik zakończył przetwarzanie wszystkich swoich wierszy.: 1291: obiekt obiekt docelowy OLE DB: 1304 : Wejście obiekt docelowy DB OLE

OnPipelinePrePrimeOutput

Składnik zostanie wywołana PrimeOutput.: 1180: Sortowanie

Składnik zostanie wywołana PrimeOutput.: 1: urządzenie źródłowe DB OLE

OnPipelineRowsSent

Wiersze zostały dostarczone do składnik przepływ danych jako dane wejściowe.:: 1185: Wyjście OLE DB urządzenie źródłowe: 1180 : Sortowanie: 1181 : Sortuj dane wejściowe: 76

Wiersze zostały dostarczone do składnik przepływ danych jako dane wejściowe.:: 1308: Wyjście sortowania: 1291 : OLE DB obiekt obiekt docelowy: 1304 : Dane wejściowe obiekt docelowy DB OLE: 76

PipelineComponentTime

Składnik "Oblicz LineItemTotalCost (3522)" wydanego 356 milisekund ProcessInput.

Składnik "Sum ilość i LineItemTotalCost" (3619) wydanego 79 milisekund ProcessInput.

Składnik "Obliczyć średni koszt" (3662) wydanego 16 milisekund ProcessInput.

Składnik "Sortuj według IDProduktu" (3717) wydanego 125 milisekund ProcessInput.

Składnik "Ładowania danych" (3773) wydanego 0 milisekund ProcessInput.

Składnik "Wyodrębnij dane (3869)" wydanego 688 milisekund PrimeOutput wypełnianie buforów na wyjściu "OLE DB urządzenie źródłowe wyjście" (3879).

Składnik "Sum ilość i LineItemTotalCost" (3619) poświęconego 141 milisekund PrimeOutput wypełnianie buforów na wyjściu "agregacja wyjściowy 1" (3621).

Składnik "Sortuj według IDProduktu" (3717) wydanego 16 milisekund PrimeOutput wypełnianie buforów na wyjściu "Sortuj wyjście" (3719).

PipelineExecutionPlan

SourceThread0

Dyski: 1

Czynników: 1180 1291

Lista Praca w danych wyjściowych

CreatePrimeBuffer typu 1 dla wyjścia 11 identyfikator.

SetBufferListener: "WorkThread0" do wprowadzania IDENTYFIKATORA 1181

CreatePrimeBuffer typu 3 dla wyjścia 12 identyfikator.

CallPrimeOutput składnika "OLE DB urządzenie źródłowe" (1)

Koniec danych wyjściowych Praca listy

Koniec SourceThread0

WorkThread0

Dyski: 1180

Czynników: 1180 1291

Wprowadzanie pracy listy, wprowadź identyfikator 1181 (1 EORs przewidywane)

CallProcessInput w wejściowym 1181 identyfikator składnika "Sortuj" (1180) dla typu widoku 2

Koniec wprowadzania Praca listy dla 1181 wejściowe

Lista Praca w danych wyjściowych

CreatePrimeBuffer typu 4 dla wyjścia 1182 identyfikator.

SetBufferListener: "WorkThread1" do wprowadzania IDENTYFIKATORA 1304

CallPrimeOutput składnika "Sortuj" (1180)

Koniec danych wyjściowych Praca listy

Koniec WorkThread0

WorkThread1

Dyski: 1291

Czynników: 1291

Wprowadzanie pracy listy, wprowadź identyfikator 1304 (1 EORs przewidywane)

CallProcessInput w wejściowym 1304 identyfikator składnika "OLE DB docelowa" (1291) dla typu widoku 5

Koniec wprowadzania Praca listy dla 1304 wejściowe

Lista Praca w danych wyjściowych

Koniec danych wyjściowych Praca listy

Koniec WorkThread1

PipelineExecutionTrees

Rozpocznij drzewo wykonania 0

dane wyjściowe "OLE DB urządzenie źródłowe wyjście" (11)

dane wejściowe "Sortuj wprowadzania" (1181)

zakończenie wykonywania drzewa 0

Rozpocznij drzewo wykonania 1

dane wyjściowe "OLE DB urządzenie źródłowe błędu wyjście" (12)

zakończenie wykonywania drzewa 1

Rozpocznij drzewo wykonania 2

dane wyjściowe (1182) "Sortowanie danych wyjściowych"

dane wejściowe "OLE DB obiekt obiekt docelowy wprowadzania" (1304)

dane wyjściowe "OLE DB obiekt obiekt docelowy o wyjście" (1305)

zakończenie wykonywania drzewa 2

PipelineInitialization

Nie tymczasowej lokalizacji przechowywania danych BLOB zostały dostarczone.Menedżer bufor będzie poprzedzał katalogi w zmienne środowiskowe TEMP i TMP.

Domyślny rozmiar buforu jest 10485760 bajtów.

Bufory ma domyślnie 10 000 wierszy

Przepływ danych nie powoduje usunięcia nieużywanych składników, ponieważ jego właściwość RunInOptimizedMode zestaw do fałszywych.

Wiele zdarzeń dziennika zapisu wiele zapisów i wiadomości dla pewnej liczby wpisów dziennika zawierają złożone dane.Aby ułatwić zrozumienie i komunikację treść komunikatów złożonych można analizować tekstu wiadomości.W zależności od lokalizacji w dziennikach można użyć instrukcji języka Transact-SQL lub składnik skryptów do oddzielania tekstu złożonego do kolumn lub inne formaty, które można znaleźć bardziej użyteczne.

Na przykład poniższa tabela zawiera komunikat „ wiersze zostały dostarczone ze składnikiem przepływ danych jako dane wejściowe.:: 1185: Wyjście OLE DB urządzenie źródłowe: 1180 : Sortowanie: 1181 : Sortuj dane wejściowe: 76. ", w sytuacji, w kolumnach.Komunikat został napisany przez OnPipelineRowsSent zdarzenie, kiedy wiersze zostały wysłane z OLE DB urządzenie źródłowe do przekształcania sortowanie.

Kolumna

Description

Wartość

PathID

Wartość z ID Właściwość ścieżka między źródłową OLE DB i do sortowania transformacja.

1185

Ścieżka

Wartość z Name Właściwość ścieżka.

Wyjście urządzenie źródłowe DB OLE

ComponentID

Wartość ID Właściwość transformacja sortowanie.

1180

ComponentName

Wartość z Name Właściwość transformacja sortowanie.

Sortowanie

InputID

Wartość z IDENTYFIKATOR właściwość dane wejściowe do sortowania transformacja.

1181

InputName

Wartość z Name Właściwość dane wejściowe do przekształcania sortowanie.

Sortowanie wprowadzania

RowsSent

Liczba wysłanych danych wejściowych transformacja sortowania wierszy.

76

Źródła

Następujących źródeł mają właściwość, które mogą być aktualizowane przez właściwość wyrażenia:

Aby uzyskać więcej informacji zobaczWłaściwości niestandardowe urządzenie źródłowe.

Przekształcenia

Miejsca docelowe

Następujące docelowe mają właściwość, które mogą być aktualizowane przez właściwość wyrażenia:

Aby uzyskać więcej informacji zobaczWłaściwości niestandardowe obiekt obiekt docelowy.

Konfigurowanie zadanie przepływ danych

zestaw właściwości Właściwości okna lub programowo.

Aby uzyskać więcej informacji na temat sposobu zestaw te właściwości w Właściwości okna, kliknij następujący temat:

Konfigurowanie zadanie przepływ danych programowe

Aby uzyskać więcej informacji na temat dodawania programowo zadaniem przepływ danych pakiet i ustawianie właściwości przepływ danych, kliknij następujący temat:

Integration Services icon (small) Konfiguracja w aktualizacji z usług integracja Services pobytu

Najnowsze pliki do pobrania, artykuły, próbki, i pliki wideo firmy Microsoft, jak również wybranego rozwiązania od Wspólnoty, odwiedź witrynę Integration Services strona w witrynie MSDN lub TechNet:

Automatycznego powiadomienie tych aktualizacji należy subskrybować źródła danych RSS, które jest dostępne strona.