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.
.gif "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.
.gif "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
Następujące przekształcenia 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 transformacja.
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:
|
.gif "Integration Services icon (small)")
Konfiguracja w aktualizacji z usług integracja Services pobytuSee Also