veri akışı görevii
Data Flow görevi saklar veri akışı altyapısı kaynak ve hedef arasında verileri taşır ve dönüştürme, temiz ve veri, hareket ettirildikçe değiştirmek sağlar.Ayrıca paket denetim akışı için veri akışı görevi paketi ayıklamak, dönüştürmek ve veri yüklemek olanaklı kılar.
Veri akışını en az bir veri akışı bileşeni içerir, ancak genellikle bağlı veri akışı bileşenleri kümesi olacaktır: veri; değiştirmek, yol veya verileri özetleme dönüştürmeleri ile yüklenen. hedefleri kaynakları Bileşenleri bağlı veri akışı yolları tarafından.Her yolun başına ve sonuna kadar yolun iki bileşeni belirtir.Daha fazla bilgi için bkz:Veri akışı öğeler.
Çalışma sırasında saat yürütme planı arasında veri akışının veri akışı görevi oluşturur ve veri akışı motoru plan yapar.Herhangi bir veri akışı olan veri akışı görevi oluşturabilirsiniz, ancak yalnızca en az bir veri akışı içeriyorsa, görevi yapar.
Aşağıdaki çizimde, bir veri akışı olan veri akışı görevi gösterir.
.gif "Data flow")
Birden çok veri akışlarının veri akışı görevi ekleyebilirsiniz.Göreve birden fazla veri kümesi kopyalar ve verilerin kopyalandığı siparişi önemli değilse, birden çok veri akışlarının veri akışı görevi eklemek daha uygun olabilir.Örneğin, beş veri akışı, her kopyalama veri düz bir dosyadan veri ambarı yıldız şemasındaki farklı boyut tablosu oluşturabilirsiniz.
Ancak, bir veri akışı görevi içinde birden çok veri akışı olduğunda veri akışı motoru yürütme sırasını belirler.Bu nedenle, paket sırası önemlidir, her görev bir veri akışı içeren birden çok veri akışı görevleri kullanmalısınız.Daha sonra görevleri yürütme sırasını denetlemek için öncelik kısıtlamaları uygulayabilirsiniz.
Aşağıdaki çizimde birden çok veri akışlarının veri akışı bir görevi gösterir.
.gif "Data flows")
Bir paket birden çok veri akışı görevler içerebilir ve karmaşık paket sık yapın.Örneğin, veri akışı belirli bir sırada çalıştırılacak bir paket gerektirir ve diğer görevler veri akışı gerçekleştirilecek her veri akışı için ayrı bir veri akışı görevi kullanmalısınız.
veri akışı görevi de hata akışı yönetir.Çalışma zamanında veri bileşenleri dönüştürme veri akışı, bir arama yapmak veya deyimleri değerlendirmek satır düzey hatalar oluşabilir.Örneğin, bir veri sütununu içeren bir dize değeri tamsayıya dönüştürülemez ya da sıfıra bölme ifade çalışır.Her iki işlem hataya neden olur ve hatalar içeren satırları ayrı ayrı bir hata akışı kullanılarak işlenebilir.Paket veri akış hata akışlarında kullanma hakkında daha fazla bilgi için bkz:Verileri işleme hatası.
Toplu ekleme verileri metin dosyalarına için birSQL Serververitabanı, veri akışı görevi ve veri akışını. yerine Ekle toplu görev kullanabilirsinizAncak, toplu Ekle görev verilerini dönüştürmek olamaz.Daha fazla bilgi için bkz:Toplu ekleme görev.
Özellik ifadeleri veri akışı öðelerle kullanmak
Çok sayıda veri akışı bileşenleri — kaynakları, dönüştürmeleri ve hedefleri; bazı özelliklerini özellik ifadelerin kullanımını destekler.Bir özellik ifade paket yüklendiğinde, özellik değerinin yerini alan ifade.Çalışma sırasında saat, paketin güncelleştirilen özellik değerlerini kullanır.İfadeler kullanılarak yüklenenIntegration Servicesifade sözdizimi ve kullanılabilirIntegration Servicesişlevleri, işleçlerin, tanımlayıcıların ve değişkenleri.Daha fazla bilgi için bkz:Tümleştirme Hizmetleri ifade başvurusu,Paketlerinde ifadeleri kullanma, vePaketlerinde özellik ifadeleri kullanma.
Yoksa, bir paket oluşturmaBusiness Intelligence Development Studio, ait oldukları veri akışı görevi özelliklerini özellik ifadeleri destekleyen diğer veri akışı bileşenleri sunulmuştur.Eklemek, değiştirmek ve özellik ifadeleri veri akışı bileşenleri kaldırmak, veri akışı görevi tıklatın ve sonra eklemek için Properties penceresini veya görev için düzenleyici kullanın, değiştirme veya özellik ifadeleri silin.veri akışı görevi kendisi için özellik ifadeleri, Properties penceresinde yönetilir.
Veri akışı ifadeleri kullanan tüm bileşenleri varsa, ifadeler Properties penceresinde de gösterilir.İfadeleri görüntülemek için bileşenin ait olduğu veri akışı görevi seçin.Kategorilere göre veya alfabetik olarak özelliklerini görüntüleyebilirsiniz.Properties penceresinde kategorilere ayrılan görünümü kullanıyorsanız, belirli bir özellikte kullanılan tüm ifadeleri listelenenDiğer kategori. Alfabetik görünümü kullanıyorsanız, ifadeleri adı sırayla listelenir veri akışı bileşeni.
Günlük girişleri
Integration Services provides a set of log events that are available to all tasks.Integration Services also provides custom log entries to many tasks.Daha fazla bilgi için bkz:Paketlerinde günlüğü uygulamaveOturum için özel iletiler.veri akışı görevi aşağıdaki özel günlük girdileri içerir:
Günlük girdisi |
Açıklama |
|---|---|
BufferSizeTuning |
veri akışı görevi arabelleğinin boyutunu değişiklik gösterir.Günlük girişi, boyutu değiştirme nedenleri açıklanır ve geçici yeni arabellek boyutunu listeler. |
OnPipelinePostEndOfRowset |
Bir bileşeni olan son çağrı tarafından satır kümesi kümesi sonu sinyal verilmiş gösterirProcessInputyöntem.Giriş işlemleri veri akışı her bileşen için bir girdi yazılır.Giriş bileşenin adını içerir. |
OnPipelinePostPrimeOutput |
Bileşeni, son çağrı tamamlandığını gösterirPrimeOutputyöntem.Bağlı veri akışı, birden çok günlük girdisi yazılabilir.Bileşen kaynak ise, bu günlük girdisi bileşeni işlem satırları tamamlandı anlamına gelir. |
OnPipelinePreEndOfRowset |
Gösterir son çağrı tarafından küme, satır kümesi kümesi sonu sinyal almaya bir bileşeni olanProcessInputyöntem.Giriş işlemleri veri akışı her bileşen için bir girdi yazılır.Giriş bileşenin adını içerir. |
OnPipelinePrePrimeOutput |
Bileşeni, çağrısından almaya olduğunuPrimeOutputyöntem.Bağlı veri akışı, birden çok günlük girdisi yazılabilir. |
OnPipelineRowsSent |
Çağrısıyla bileşen giriş olarak sağlanan satır sayısı bildiriyorProcessInputyöntem.Günlük girdisinin, bileşen adı içerir. |
PipelineBufferLeak |
Arabellek yöneticisine kaybolduktan sonra arabellek Canlı tutulan tüm bileşenler hakkında bilgi sağlar.Arabellek çalışır, arabellek kaynakları yayımlanmış olan ve Bellek sızıntılarını neden olabilir.Günlük girişi bileşenin adını ve Kimliğini arabellek sağlar. |
PipelineComponentTime |
Bileşen her birinde, beş ana işlem adımları geçen saat (milisaniye cinsinden) miktarını bildirir; doğrula, PreExecute, PostExecute, ProcessInput ve ProcessOutput. |
PipelineExecutionPlan |
Veri akışı yürütme planını bildirir.Yürütme planı arabellek bileşenleri nasıl gönderileceği hakkında bilgi sağlar.PipelineExecutionTrees günlük girişi, birlikte bu bilgiler, veri akışı görevi içinde neler olduğunu tanımlar. |
PipelineExecutionTrees |
Veri akışı düzenini yürütme ağaçları bildirir.Zamanlayıcı veri akışı in ağaçları veri akışının yürütme planı oluşturmak için kullanır. |
PipelineInitialization |
Görev başlatma bilgilerini sağlar.Bu bilgiler BLOB verileri, varsayılan arabellek boyutu ve satır arabellekte geçici depolama için dizinleri içerir.veri akışı görevi yapılandırmasına bağlı olarak, birden çok günlük girdisi yazılabilir. |
Bu günlük girdileri bir çok yürütülmesi hakkında bilgi sağlayan veri akışı görevi her bir paketni çalıştırın.Paketleri sürekli olarak çalışırken, saat içinde önemli geçmiş hakkında bilgi sağlayan görev yapan işleme performansını etkileyebilecek sorunlar ve işleme görev veri birimi bilgileri yakalayabilir.
Bu günlük girdileri izlemek ve veri akış performansını artırmak için kullanma hakkında daha fazla bilgi için aşağıdaki konulardan birini görürsünüz:
Görev örnek iletiler gönderen bir veri akışı
Aşağıdaki tabloda örnek çok basit bir paket için günlük girdilerini iletileri listeler.Bir tablodaki verileri sıralamak için sıralama dönüştürme veri ayıklamak için bir OLE DB kaynak paket kullanır ve bir OLE DB hedef veri için farklı bir tablo yazar.
Günlük girdisi |
İletiler |
|---|---|
BufferSizeTuning |
Ara bellek türü 0 satırları, yapılandırılmış en büyük değerden daha büyük bir arabellek boyutu neden olur.Olacaktır yalnızca 9637 satır içindeki bu tür arabellekler. Ara bellek türü 2 satırları, yapılandırılmış en büyük değerden daha büyük bir arabellek boyutu neden olur.Olacaktır yalnızca 9497 satır içindeki bu tür arabellekler. Ara bellek türü 3 satırları, yapılandırılmış en büyük değerden daha büyük bir arabellek boyutu neden olur.Olacaktır yalnızca 9497 satır içindeki bu tür arabellekler. |
OnPipelinePostEndOfRowset |
Bir bileşen kümesi sinyal sonunda verilir.: 1180: Sıralama: 1181 : Sıralama giriş Bir bileşen kümesi sinyal sonunda verilir.: 1291: OLE DB hedef: 1304 : OLE DB hedef giriş |
OnPipelinePostPrimeOutput |
Bir bileşeni, PrimeOutput çağrısından verdi.: 1180: Sıralama Bir bileşeni, PrimeOutput çağrısından verdi.: 1: OLE DB kaynağı |
OnPipelinePreEndOfRowset |
Bir bileşen satırlarını tüm işlem tamamlandı.: 1180: Sıralama: 1181 : Sıralama giriş Bir bileşen satırlarını tüm işlem tamamlandı.: 1291: OLE DB hedef: 1304 : OLE DB hedef giriş |
OnPipelinePrePrimeOutput |
PrimeOutput üzerindeki verilir.: 1180: Sıralama PrimeOutput üzerindeki verilir.: 1: OLE DB kaynağı |
OnPipelineRowsSent |
Satır bir veri akışı bileşenine giriş olarak sağlanan.:: 1185: OLE DB kaynak çıktı: 1180 : Sıralama: 1181 : Sort girişi: 76 Satır bir veri akışı bileşenine giriş olarak sağlanan.:: 1308: Sıralama çıktı: 1291 : OLE DB hedef: 1304 : OLE DB hedef girişi: 76 |
PipelineComponentTime |
"LineItemTotalCost Hesapla" (3522) bileşeni ProcessInput 356 milisaniye harcanan. "Toplam miktar ve LineItemTotalCost" (3619) bileşeni, ProcessInput 79 milisaniye harcanan. "Hesapla ortalama maliyeti" (3662) bileşeni için 16 milisaniye ProcessInput harcanan. "Sıralama ile ProductID" (3717) bileşeni ProcessInput 125 milisaniye harcanan. "Load Data" (3773) bileşeni, ProcessInput 0 milisaniye harcanan. "Veri Ayıkla" (3869) bileşeni 688 milisaniye (3879) arabelleği çıktıyı "OLE DB kaynak çıktı" doldurma PrimeOutput harcanan. 141 Milisaniye PrimeOutput arabellek çıktıyı "toplamak çıktı 1" doldurma "toplamak miktar ve LineItemTotalCost" (3619) bileşeni harcanan (3621). 16 Milisaniye PrimeOutput (3719) arabelleği çıktıyı "Sıralama çıktı" doldurma "Sıralama ile ProductID" (3717) bileşeni harcanan. |
PipelineExecutionPlan |
SourceThread0 Sürücü: 1 Etkiler: 1180 1291 Çıktı çalışma listesi Tip 1 için CreatePrimeBuffer Kimliği 11 çıktı. SetBufferListener: Girdi kimliği 1181 için "WorkThread0" Tip 3 için CreatePrimeBuffer Kimliği 12 çıktı. CallPrimeOutput bileşeni "OLE DB kaynak" (1) Son Çıktı iş listesi Son SourceThread0 WorkThread0 Sürücü: 1180 Etkiler: 1180 1291 İş listesi giriş, 1181 (1 EORs beklenen) kodu gir Girdi kimliği 1181 2 görünüm türü için "Sıralama" (1180) bileşeni, CallProcessInput Son giriş çalışma listesi giriş 1181 Çıktı çalışma listesi Tip 4 için CreatePrimeBuffer Kimliği 1182 çıktı. SetBufferListener: Girdi kimliği 1304 için "WorkThread1" CallPrimeOutput bileşeni "Sıralama" (1180) Son Çıktı iş listesi Son WorkThread0 WorkThread1 Sürücü: 1291 Etkiler: 1291 İş listesi giriş, 1304 (1 EORs beklenen) kodu gir CallProcessInput bileşeni "OLE DB hedef" (1291) görünüm türü 5 için giriş kimliği 1304 hakkında Son giriş çalışma listesi giriş 1304 Çıktı çalışma listesi Son Çıktı iş listesi Son WorkThread1 |
PipelineExecutionTrees |
başlamadan 0 yürütme ağacı Çıktı "OLE DB kaynak çıktı" (11) "Sıralama Giriş" (1181) giriş Son yürütme ağacının 0 başlamadan 1 yürütme ağacı "OLE DB kaynak hatası çıktı" (12) çıkış Son yürütme ağacının 1 başlamadan 2 yürütme ağacı "Sıralama çıktı" (1182) çıkış "OLE DB hedef giriş" (1304) giriş "OLE DB hedef hatası çıktı" (1305) çıkış Son yürütme ağacının 2 |
PipelineInitialization |
Sağlanan geçici olmayan BLOB veri depolama konumu.Arabellek yöneticisine dizinler TEMP ve TMP ortam değişkenleri kabul eder. Varsayılan arabellek boyutu 10485760 bayttır. Varsayılan olarak arabellek 10000 satır sahip olur RunInOptimizedMode özellik olduğu için veri akışı kullanılmayan bileşenleri kaldıracak küme çok yanlış. |
Birçok günlük olay birden çok girdi yazmak ve iletiler için günlük girdilerini çok sayıda karmaşık veri içerir.Anlamak ve karmaşık ileti içeriği iletişim kurmak için kolaylaştırmak için ileti metni ayrıştırılamıyor.Günlükleri konumuna bağlı olarak, karmaşık metin sütunları veya diğer biçimleri, daha kullanışlı ayırmak için Transact-SQL deyimi veya bir komut dosyası bileşeni kullanabilirsiniz.
Örneğin, aşağıdaki tabloda message "satır veri akışı bileşenine giriş olarak sağlanan. içerir.:: 1185: OLE DB kaynak çıktı: 1180 : Sıralama: 1181 : Sort girişi: 76 "sütunları. ayrıştırıldı İleti tarafından yazılanOnPipelineRowsSentolay, satır gönderilen OLE DB kaynak sıralama dönüştürme.
Sütun |
Açıklama |
Değer |
|---|---|---|
PathID |
DeğeriIDözellik yolun OLE DB kaynağı ve sıralama dönüştürme. |
1185 |
Yol adı |
DeğeriNameyol özellik |
OLE DB kaynak çıktı |
ComponentId |
Değeri,IDözellik sıralama dönüştürme. |
1180 |
ComponentName |
DeğeriNameözellik sıralama dönüştürme. |
Sıralama |
InputID |
DeğeriID Giriş sıralama dönüştürme. özellik |
1181 |
InputName |
DeğeriNameözellik giriş sıralama dönüştürme. |
Sıralama giriş |
RowsSent |
Sıralama dönüştürme için giriş gönderilen satır sayısı. |
76 |
Kaynaklar
Aşağıdaki kaynaklar özellik ifadeleri tarafından güncelleştirilen özelliklere sahiptir:
Daha fazla bilgi için bkz:Kaynak özel özellikleri.
Dönüştürme
Aşağıdaki dönüştürme özellik ifadeler tarafından güncelleştirilen özelliklere sahiptir:
Daha fazla bilgi için bkz:Dönüştürme için özel özellikler.
Hedefleri
Aşağıdaki hedefleri özellik ifadeleri tarafından güncelleştirilen özelliklere sahiptir:
Daha fazla bilgi için bkz:Hedef özel özellikleri.
veri akışı görevi yapılandırma
Yapabilirsiniz küme özelliklerindeÖzellikleri pencere veya programla.
Bu özellikleri ayarlamak hakkında daha fazla bilgi içinÖzellikleri penceresinde aşağıdaki konuyu tıklatın:
Veri akışı görevi programatik olarak yapılandırma
Paket ve veri akışı özelliklerini, veri akışı göreve programlı olarak ekleme hakkında daha fazla bilgi için aşağıdaki konuya tıklatın:
|
.gif "Integration Services icon (small)")
tümleştirme Services ile güncel kalınSee Also