<h4 class="wp-block-heading"><strong>Sqoop Nedir?</strong></h4>



<p class="wp-block-paragraph">Apache Sqoop, ilişkisel veri tabanları ile hadoop arasında büyük verilerin aktarımını sağlayan java tabanlı bir yazılımdır. Her iki yönde aktarım yapabilmektedir. Veriyi ilişkisel veri tabanından okuyup (Oracle, MySQL, SQL Server, Postgres, Teradata vs) hadoop dağıtık dosya sistemine (HDFS, Hive, Hbase …) aktarabildiği gibi hadoop ortamından okuyup ilişkisel veri tabanlarına da yazılabilmesini sağlar.</p>



<figure class="wp-block-image size-full"><a href="https://www.ayhanarda.com/blog/wp-content/uploads/2023/03/image-1.png"><img src="https://www.ayhanarda.com/blog/wp-content/uploads/2023/03/image-1.png" alt="" class="wp-image-1547"/></a></figure>



<p class="wp-block-paragraph">Sqoop, &#8220;SQL&#8217;den Hadoop&#8217;a ve Hadoop&#8217;tan SQL&#8217;e&#8221; anlamına gelir ve Cloudera tarafından geliştirilmiştir.</p>



<p class="wp-block-paragraph">Sqoop’un avantajı ise veri aktarım işlemlerini MapReduce görevleri ile paralel olarak yaparak aktarımı çok daha hızlı tamamlamak. Ayrıca MySQL ve PostgreSQL için JDBC kullanmadan (mysqldump gibi) daha düşük seviyeli ve performanslı veri aktarımı da yapılabiliyor.</p>



<p class="wp-block-paragraph">İmport işlemi sırasında Sqoop basitçe meta verilerden faydalanarak tablonun birincil anahtarını bulup minimum ve maksimum değerlerini alarak eşit olarak Map sayısına uygun olarak bölerek farklı düğümler üzerinde bu verileri paralel olarak aktarır. Bu yüzden sonuç klasör içinde birden fazla dosyaya yazılır. Aktarım sırasında veritabanına yeni kayıt geliyorsa bunlar aktarılmayabilir, veri tutarlılığına dikkat etmek gerekir.</p>



<p class="wp-block-paragraph">Export işlemi sırasında ise aksi belirtilmediği sürece verileri binerli gruplar halinde veritabanına INSERT ediyor. Bu işlem de paralel olarak yapıldığı için aktarım sırasında veritabanında yük oluşturabilir. Her bir grubun yazılması kendi başına bir transaction olduğu için burada da veri tutarlılığına dikkat etmek gerekir. Eğer kayıtların tamamı aktarıldıktan sonra aktif olması isteniyorsa ara tablo kullanımını sağlayan –staging-table parametresi kullanılabilir. Bu tablonun yaratılması ve temizlenmesi de otomatik yapılmaz, elle yapmak gerekir.</p>



<figure class="wp-block-image size-full"><a href="https://www.ayhanarda.com/blog/wp-content/uploads/2023/03/image.png"><img src="https://www.ayhanarda.com/blog/wp-content/uploads/2023/03/image.png" alt="" class="wp-image-1544"/></a><figcaption class="wp-element-caption">Sqoop</figcaption></figure>



<p class="wp-block-paragraph">Hadoop geliştiricisi için asıl olay veriler HDFS&#8217;ye yüklendikten sonra başlar. HDFS&#8217;de depolanan verilerde gizlenmiş çeşitli ön görüler elde etmek için bu veriler etrafında işlemler yapılır.</p>



<p class="wp-block-paragraph">Bu nedenle, bu analiz için ilişkisel veri tabanı yönetim sistemlerinde bulunan verilerin HDFS&#8217;ye aktarılması gerekir. İlişkisel veritabanından HDFS&#8217;ye veri almak ve vermek için MapReduce kodunu yazma görevi çok ilgi çekici değildir ve sıkıcıdır. Apache Sqoop&#8217;un kurtarmaya geldiği ve acılarını dindirdiği yer burasıdır. Verileri içe ve dışa aktarma sürecini otomatikleştirir.</p>



<p class="wp-block-paragraph">Sqoop, verileri içe ve dışa aktarmak için CLI sağlayarak geliştiricilerin hayatını kolaylaştırır. Sadece veritabanı kimlik doğrulaması, kaynak, hedef, işlemler vb. gibi temel bilgileri sağlamaları gerekir. Geri kalan kısmı o halleder.</p>



<p class="wp-block-paragraph">Sqoop, komutu dahili olarak, daha sonra HDFS üzerinden yürütülen MapReduce görevlerine dönüştürür. Paralellik üzerinde hata toleransı sağlayan verileri içe ve dışa aktarmak için YARN çerçevesini kullanır.</p>



<p class="wp-block-paragraph"><strong>Sqoop Özellikleri</strong></p>



<ol class="wp-block-list">
<li>Sağlamlık: Apache Sqoop doğası gereği oldukça sağlamdır. Topluluk desteği ve katkısı vardır ve kolayca kullanılabilir.</li>



<li>Tam Yük: Sqoop kullanarak, tek bir Sqoop komutuyla tüm tabloyu yükleyebiliriz. Sqoop ayrıca tek bir Sqoop komutu kullanarak veritabanındaki tüm tabloları yüklememizi sağlar.</li>



<li>Artımlı Yük: Sqoop, artımlı yük işlevselliğini destekler. Sqoop&#8217;u kullanarak, güncellendiğinde tablonun bölümlerini yükleyebiliriz.</li>



<li>Paralel içe/dışa aktarma: Apache Sqoop, verileri içe ve dışa aktarmak için YARN çerçevesini kullanır. Bu, paralelliğin üstünde hata toleransı sağlar.</li>



<li>SQL sorgusunun sonuçlarını içe aktarın: Sqoop, SQL sorgusundan döndürülen sonucu Hadoop Dağıtılmış Dosya Sistemine içe aktarmamıza da izin verir.</li>



<li>Sıkıştırma: -compress argümanı ile deflate(gzip) algoritmasını kullanarak veya –compression-codec argümanını belirterek verilerimizi sıkıştırabiliriz. Apache Hive&#8217;a sıkıştırılmış bir tablo yükleyebiliriz.</li>



<li>Tüm önemli RDBMS Veritabanları için konnektörler: Sqoop, çeşitli RDBMS veritabanları için neredeyse tüm ekosistemi kapsayan konnektörler sağlar.</li>



<li>Kerberos Güvenlik Entegrasyonu: Temel olarak Kerberos, güvenli olmayan ağ üzerinden iletişim kuran düğümlerin kimliklerini birbirlerine kanıtlamalarına izin vermek için ticketlar temelinde çalışan bilgisayar ağı kimlik doğrulama protokolüdür. Apache Sqoop, Kerberos kimlik doğrulamasını destekler.</li>



<li>Verileri doğrudan HIVE/HBase&#8217;e yükleyin: Sqoop&#8217;u kullanarak, veri analizi için verileri doğrudan Hive&#8217;a yükleyebiliriz. Verilerimizi HBase yani NoSQL veritabanına da dump edebiliriz.</li>



<li>Accumulo Desteği: Apache Sqoop&#8217;a bir tabloyu HDFS&#8217;deki bir dizine almak yerine Accumulo&#8217;ya alması talimatını verebiliriz.</li>
</ol>



<p class="wp-block-paragraph"><strong>Sqoop&#8217;un Sınırlamaları</strong></p>



<ol class="wp-block-list">
<li>Apache Sqoop&#8217;u duraklatamaz ya da devam ettiremeyiz. atomik bir adımdır.</li>



<li>Sqoop Export&#8217;un performansı, RDBMS sunucusunun donanım ya da config yapılandırmasına bağlıdır.</li>



<li>Sqoop MapReduce paradigmasını kullanır.</li>



<li>İmport ya da export sırasındaki problemler için özel işlem gerektirir.</li>



<li>Her rdbms konnektörü aynı değildir , bazı veritabanları için daha bulk işlemler sağlar.</li>
</ol>



<p class="wp-block-paragraph"><strong>Sqoop Argümanları</strong></p>



<figure class="wp-block-table"><table><thead><tr><th>Argüman</th><th>Açıklama</th></tr></thead><tbody><tr><td><code>--append</code></td><td>Import edilen veriyi HDFS’deki mevcut veriye ekler</td></tr><tr><td><code>--as-avrodatafile</code></td><td>Veriyi Avro Data Files olarak import eder</td></tr><tr><td><code>--as-sequencefile</code></td><td>Veriyi SequenceFiles olarak import eder</td></tr><tr><td><code>--as-textfile</code></td><td>Veriyi plain text olarak import eder. Varsayılan format budur.</td></tr><tr><td><code>--as-parquetfile</code></td><td>Veriyi Parquet Files olarak import eder</td></tr><tr><td><code>--boundary-query <;statement>;</code></td><td>Sorguya kullanıcı tarafından konan sınırdır.</td></tr><tr><td><code>--columns <;col,col,col…>;</code></td><td>Tablonun hangi sütunlarını seçeceğimizi bildiririz.</td></tr><tr><td><code>--delete-target-dir</code></td><td>Eğer hedefte böyle bir dizin varsa onu siler.</td></tr><tr><td><code>--direct</code></td><td>Veri tabanı için varsa doğrudan bağlantı kullanır.</td></tr><tr><td><code>--fetch-size <;n>;</code></td><td>Çağrılacak satır sayısına sınır koyulur. 50 satır getir gibi.</td></tr><tr><td><code>--inline-lob-limit <;n>;</code></td><td>Bir satırda bulunacak maksimum LOB genişliği.</td></tr><tr><td><code>-m,--num-mappers <;n>;</code></td><td>Kaç tane paralel map görevinin paralel çalışacağını belirten rakamdır.</td></tr><tr><td><code>-e,--query <;statement>;</code></td><td>Import the results of ;<em><code>statement</code></em>.</td></tr><tr><td><code>--split-by <;column-name>;</code></td><td>Tablonun hangi sütun baz alınarak bölüneceğini belirtir.  ;<code>--autoreset-to-one-mapper</code> ;ile aynı anda kullanılamaz.</td></tr><tr><td><code>--autoreset-to-one-mapper</code></td><td>Eğer tabloda primary key yok ise ve bölünecek sütun da belirtilmemişse tek bir mapper kullanılır.  ;Aynı anda ;<code>--split-by <;col>;</code> ;seçeneği ile kullanılamaz.</td></tr><tr><td><code>--table <;table-name>;</code></td><td>Okunmak istenen hedef tablonun ismi</td></tr><tr><td><code>--target-dir <;dir>;</code></td><td>Hedef HDFS dizini</td></tr><tr><td><code>--warehouse-dir <;dir>;</code></td><td>HDFS parent for table destination</td></tr><tr><td><code>--where <;where clause>;</code></td><td>Eğer import esnasında WHERE  ;koşulu kullanmak istiyorsak.</td></tr><tr><td><code>-z,--compress</code></td><td>Sıkıştırmayı açmak istiyorsak</td></tr><tr><td><code>--compression-codec <;c>;</code></td><td>Hadoop codec kullanımı (varsayılan gzip)</td></tr><tr><td><code>--null-string <;null-string>;</code></td><td>Sütun string ise ve null ise bunun yerine yazılacak string. Örneğin null geldininde “Boş” yazılmasını istersek.</td></tr><tr><td><code>--null-non-string <;null-string>;</code></td><td>Sütun string değil ise null değerler için alacak değer</td></tr></tbody></table><figcaption class="wp-element-caption">Sqoop Argümanları</figcaption></figure>



<p class="wp-block-paragraph"><strong>Örnekler;</strong></p>



<p class="wp-block-paragraph"><strong>Mysql sunucusundaki personeller veritabanındaki tabloları listeleyelim.</strong></p>



<pre class="wp-block-code"><code><strong>sqoop list-tables --connect jdbc:mysql://MYSQLDBADRESINIZ:3306/personel --username ayhanarda -P</strong>
Enter password:
23/03/15 19:59:31 INFO manager.MySQLManager: Preparing to use a MySQL streaming resultset.
departmanlar
departman_calisanlari
departman_yoneticileri
calisanlar
unvanlar
maaslar

<strong>Çalışanlar tablosunu HDFS üzerine aktaralım.</strong>

sqoop import --connect jdbc:mysql://<strong>MYSQLDBADRESINIZ</strong>:3306/personel --username ayhanarda -P --table calisanlar

<strong>Personel veritabanını direkt Hive a alalım.</strong>

sqoop import-all-tables --connect jdbc:mysql://<strong>MYSQLDBADRESINIZ</strong>:3306/personel --username ayhanarda -P --direct --hive-import

Bu aktarım işlemini –direct parametresi ile de yapabilirdik.Bu durumda jdbc konnektörü yerine mysql dump kullanırdı ve süre değişirdi.

Sqoop ile tablonun tamamını da aktarmak zorunda değiliz, -query parametresi ile sadece verdiğimiz sorgu sonucunun aktarılmasını sağlayabiliriz. Bunun dışında varsayılan olarak metin dosyası haline aktarılan verilerin alan ve satır ayraçlarını belirleyebiliriz, metin dosyaları dışında Hadoop’un binary formatı olan SequenceFile veya Avro formatında da veriler aktarılabiliriz.</code></pre>



<p class="wp-block-paragraph"><a href="https://sqoop.apache.org/docs/1.4.6/SqoopUserGuide.html" target="_blank" rel="noopener" title="">Apache Sqoop Kullanıcı Rehberi</a>ne erişmek için tıklayınız.<br><a href="https://docs.cloudera.com/sqoop/1.4.7.7.1.6.0/user-guide/index.html" target="_blank" rel="noopener" title="">Cloudera Sqoop Rehberi</a>ne erişmek için tıklayınız.</p>



<p class="wp-block-paragraph">Ayhan ARDA</p>



<p class="wp-block-paragraph"></p>