Veri akışı görev

Makale
10/29/2012

Veri akışı görev veri akışı altyapısı, veri kaynakları ve hedefleri arasında taşır ve dönüşümü, temiz ve o taşınırken verileri değiştirmek sağlar saklar. Veri akışı görev bir paket akış denetimi için ek paketi ayıklamak dönüştürmek ve veri yüklemek mümkün kılar.

En az bir veri akışı bileşen veri akışı oluşur, ancak bu genellikle bağlı veri akışı bileşenler kümesi: veri; kaynakları değiştirmek, yönlendirmek veya verileri özetlemek dönüşümleri; ve veri yüklemek gidilecek.

Çalıştırma sırasında veri akışı görev veri akışı yürütme planı oluşturur ve plan veri akışı altyapısı yürütür. Herhangi bir veri akışı içeren veri akışı görev oluşturabilir, ancak yalnızca en az bir veri akışı içeriyorsa, görevini yürütür.

Bulk INSERT veri metin dosyalarından bir SQL Serververitabanı, veri akışı görev ve veri akışı yerine Ekle toplu görev kullanabilirsiniz. Bununla birlikte, Ekle toplu görev verilerini dönüştürmek olamaz. Daha fazla bilgi için, bkz. BULK INSERT görev.

Birden çok akış

Birden çok veri akışlarının veri akışı görev ekleyebilirsiniz. Bazı veri kümelerinin görev kopyalar ve eğer hangi veriler kopyalanır sırası önemli değildir, birden çok veri akışlarının veri akışı görev eklemek daha uygun olabilir. Örneğin, beş veri akışları, bir veri ambarı yıldız şema farklı boyut tablosunda düz bir dosyaya kopyalama her verilerden oluşturabilirsiniz.

Ancak, birden çok veri akışı içindeki bir veri akışı görev olduğunda veri akışı altyapısı yürütme sırasını belirler. Sırası önemlidir, bu nedenle paketi birden fazla veri akışı görev içeren bir veri akışı görev kullanmanız gerekir. Daha sonra görevleri yürütme sırasını denetlemek için önceliği kısıtlamaları uygulayabilirsiniz.

Aşağıdaki çizimde, birden çok veri akışı içeren veri akışı görev gösterir.

Veri akışları

Günlük girişleri

Integration Servicestüm görevler için kullanılabilir günlük olayları kümesi sağlar. Integration ServicesAyrıca, pek çok görev için özel günlük girdileri sağlar. Daha fazla bilgi için Implementing Logging in Packagesve Özel iletileri günlüğe kaydetme. Veri akışı görev aşağıdaki özel günlük girdisi içerir:

Günlük girdisi	Açıklama
BufferSizeTuning	Veri akışı görev arabellek boyutu değişti gösterir. Günlük girdisi boyutu değişikliği nedenleri açıklanır ve geçici yeni arabellek boyutunu listeler.
OnPipelinePostEndOfRowset	Bir bileşenin son çağrı tarafından ayarlanır ve satır kümesi sonuna sinyal verilmiş gösterir ProcessInputyöntemi. Giriş işleyen veri akışındaki her bileşeni için bir girdi yazılır. Giriş bileşenin adını içerir.
OnPipelinePostPrimeOutput	Bileşenin kendi son çağrısına tamamlandığını gösterir PrimeOutputyöntemi. Veri akışına bağlı olarak, birden çok kaydı yazılabilir. Bileşen bir kaynak ise, bu günlük girdisi bileşeni işlem satırları tamamladı anlamına gelir.
OnPipelinePreEndOfRowset	Bir bileşeni hakkında son çağrı tarafından ayarlanır, satır kümesi sonunda sinyal almak olduğunu gösteren ProcessInputyöntemi. Giriş işleyen veri akışındaki her bileşeni için bir girdi yazılır. Giriş bileşenin adını içerir.
OnPipelinePrePrimeOutput	Bileşen hakkında kendi çağrı almak olduğunu gösteren PrimeOutputyöntemi. Veri akışına bağlı olarak, birden çok kaydı yazılabilir.
OnPipelineRowsSent	Bir bileşen giriş için yapılan bir çağrı tarafından sağlanan satır sayısı bildiriyor ProcessInputyöntemi. Günlük girdisinin, bileşen adı içerir.
PipelineBufferLeak	Arabellek Yöneticisi kaybolduktan sonra arabellek canlı tutulması herhangi bir bileşeni hakkında bilgi sağlar. Arabellek hala hayatta ise, arabellek kaynakları değil yayımlanan ve belleğinde sızıntıya neden olabilir. Günlük girdisinin, bileşen adı ve arabellek Kımlığı sağlar.
PipelineComponentTime	Bileşen her beş kendi ana işleme adımlarını harcanan süreyi (milisaniye) raporları — doğrula, PreExecute PostExecute ProcessInput ve ProcessOutput.
PipelineExecutionPlan	Veri akışı yürütme planı bildirir. Yürütme planı nasıl arabellekleri bileşenleri gönderilecektir hakkında bilgi sağlar. PipelineExecutionTrees günlük girişi ile birlikte bu bilgiler, veri akışı görev içinde neler olduğunu açıklar.
PipelineExecutionTrees	Rapor düzeni veri akışı yürütme ağaçları. Veri akışı altyapısı Zamanlayıcı ağaçlar veri akışı yürütme planı oluşturmak için kullanır.
PipelineInitialization	Görevle ilgili başlatma bilgileri 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örev yapılandırmasına bağlı olarak, birden çok kaydı yazılabilir.

Bu günlük girdileri her zaman veri akışı görev yürütme hakkında bilgi paketi çalıştırdığınız bir zenginlik sağlar. Paketleri yinelemeli olarak çalıştırmak gibi zaman içinde görev gerçekleştirir işlem, performansı etkileyebilecek konuları ve kolları görev veri birimi hakkında önemli tarihsel bilgi sağlayan bilgileri yakalayabilir.

Bu günlük girdileri ve veri akışı performansını izlemek için kullanma hakkında daha fazla bilgi için aşağıdaki konulardan birine bakın:

Örnek mesaj veri akışı görev

Aşağıdaki tabloda, örnek mesaj için çok basit bir paket için günlük girdileri listeler. Verileri sıralamak için sıralama dönüşümü bir tablodan veri ayıklamak için bir ole db kaynak paketi kullanır ve ole db hedef için farklı bir tablo verileri yazar.

Günlük girdisi	İletiler
BufferSizeTuning	Rows in buffer type 0 would cause a buffer size greater than the configured maximum. There will be only 9637 rows in buffers of this type. Rows in buffer type 2 would cause a buffer size greater than the configured maximum. There will be only 9497 rows in buffers of this type. Rows in buffer type 3 would cause a buffer size greater than the configured maximum. There will be only 9497 rows in buffers of this type.
OnPipelinePostEndOfRowset	A component will be given the end of rowset signal. : 1180 : Sort : 1181 : Sort Input A component will be given the end of rowset signal. : 1291 : OLE DB Destination : 1304 : OLE DB Destination Input
OnPipelinePostPrimeOutput	A component has returned from its PrimeOutput call. : 1180 : Sort A component has returned from its PrimeOutput call. : 1 : OLE DB Source
OnPipelinePreEndOfRowset	A component has finished processing all of its rows. : 1180 : Sort : 1181 : Sort Input A component has finished processing all of its rows. : 1291 : OLE DB Destination : 1304 : OLE DB Destination Input
OnPipelinePrePrimeOutput	PrimeOutput will be called on a component. : 1180 : Sort PrimeOutput will be called on a component. : 1 : OLE DB Source
OnPipelineRowsSent	Rows were provided to a data flow component as input. : : 1185 : OLE DB Source Output : 1180 : Sort : 1181 : Sort Input : 76 Rows were provided to a data flow component as input. : : 1308 : Sort Output : 1291 : OLE DB Destination : 1304 : OLE DB Destination Input : 76
PipelineComponentTime	The component "Calculate LineItemTotalCost" (3522) spent 356 milliseconds in ProcessInput. The component "Sum Quantity and LineItemTotalCost" (3619) spent 79 milliseconds in ProcessInput. The component "Calculate Average Cost" (3662) spent 16 milliseconds in ProcessInput. The component "Sort by ProductID" (3717) spent 125 milliseconds in ProcessInput. The component "Load Data" (3773) spent 0 milliseconds in ProcessInput. The component "Extract Data" (3869) spent 688 milliseconds in PrimeOutput filling buffers on output "OLE DB Source Output" (3879). The component "Sum Quantity and LineItemTotalCost" (3619) spent 141 milliseconds in PrimeOutput filling buffers on output "Aggregate Output 1" (3621). The component "Sort by ProductID" (3717) spent 16 milliseconds in PrimeOutput filling buffers on output "Sort Output" (3719).
PipelineExecutionPlan	SourceThread0 Drives: 1 Influences: 1180 1291 Output Work List CreatePrimeBuffer of type 1 for output ID 11. SetBufferListener: "WorkThread0" for input ID 1181 CreatePrimeBuffer of type 3 for output ID 12. CallPrimeOutput on component "OLE DB Source" (1) End Output Work List End SourceThread0 WorkThread0 Drives: 1180 Influences: 1180 1291 Input Work list, input ID 1181 (1 EORs Expected) CallProcessInput on input ID 1181 on component "Sort" (1180) for view type 2 End Input Work list for input 1181 Output Work List CreatePrimeBuffer of type 4 for output ID 1182. SetBufferListener: "WorkThread1" for input ID 1304 CallPrimeOutput on component "Sort" (1180) End Output Work List End WorkThread0 WorkThread1 Drives: 1291 Influences: 1291 Input Work list, input ID 1304 (1 EORs Expected) CallProcessInput on input ID 1304 on component "OLE DB Destination" (1291) for view type 5 End Input Work list for input 1304 Output Work List End Output Work List End WorkThread1
PipelineExecutionTrees	begin execution tree 0 output "OLE DB Source Output" (11) input "Sort Input" (1181) end execution tree 0 begin execution tree 1 output "OLE DB Source Error Output" (12) end execution tree 1 begin execution tree 2 output "Sort Output" (1182) input "OLE DB Destination Input" (1304) output "OLE DB Destination Error Output" (1305) end execution tree 2
PipelineInitialization	No temporary BLOB data storage locations were provided. The buffer manager will consider the directories in the TEMP and TMP environment variables. The default buffer size is 10485760 bytes. Buffers will have 10000 rows by default The data flow will not remove unused components because its RunInOptimizedMode property is set to false.

Birden çok girdi birçok günlük olayları yazmak ve iletiler için günlük girdileri bir dizi karmaşık verileri içerir. Anlamak ve karmaşık mesajların içeriğinden iletişim kurmak için kolaylaştırmak için ileti metni ayrıştırabilirsiniz. Günlükleri konumuna bağlı olarak, karmaşık metin sütunları veya size daha kullanışlı biçimlere ayırmak için Transact-sql deyimlerinin veya Script bileşeni kullanabilirsiniz.

Örneğin, ileti "satır veri akışı bileşen giriş sağlandı. aşağıdaki tabloda verilmiştir. :: 1185: ole db kaynağı çıkış: 1180: sıralama: 1181: sıralama giriş: 76 "sütunlara ayrıştırılır,. İleti tarafından yazılmış OnPipelineRowsSentsatırları için sıralama dönüşümü ole db kaynak gönderildiğini olayı.

Sütun	Açıklama	Değer
PathID	Değeri IDözelliğini ole db kaynağı ve sıralama dönüşümü arasındaki yolu.	1185
Yol adı	Değeri Nameyolu özelliği	ole db kaynağı çıkış
ComponentId	Değeri IDözelliği Sırala dönüşümünün.	1180
BileşenAdı	Değeri Nameözelliği Sırala dönüşümünün.	Sıralama
İnputID	Değeri ID için sıralama dönüşümü giriş özelliği.	1181
InputName	Değeri Nameözelliği Sırala dönüşümünün giriş.	Sıralama giriş
RowsSent	Sırala dönüşümünün giriş gönderilen satır sayısı.	76