2020/07/09 Embulk & Digdag Online Meetup 2020

ãã¼ã¯ã«é¢ãã質åã¯Slidoã§åãä»ãã¦ãã¾ãï¼ https://app.sli.do/event/rmpbrfsv [ç®æ¬¡] 00:00 æºåä¸ã®ããã¹ããããã¦ãã ããã 46:18 ãªã¼ããã³ã° 48:26 Embulkãã©ã°ã¤ã³ãã¹ã¯ãªããã§æ¸ããããã«ãã¦ã¿ã by å¤æ©è²ä¹ Arm TreasureData(ç¾Treasure Data) 1:09:31 Plan and incompatibility toward Embulk v1.0 by ä¸å»»é¨å¤§ãArm TreasureData (ç¾Treasure Data) 1:50:22 Embulk ãå©ç¨ãããã¼ã¿çµ±åSaaSã®æ§ç¯ã¨éç¨ by é´æ¨å¥å¤ª æ ªå¼ä¼ç¤¾primeNumber 2:36:43 Digdag updates 山縣 é½ Arm TreasureData(ç¾Treasure Data) 3:09:
techplay.jp ã³ããã®å½±é¿ã§å»¶æããEmbulk & Digdag Online Meetup 2020ããªã³ã©ã¤ã³éå¬ãã¾ããã ä»åã¯ãZoom Webniarã¢ã¼ãã¨youtubeé£æºã§ã®ã©ã¤ãé ä¿¡ï¼sli.doã«ããQAãåãã¦è©¦ã¿ã¾ããããã®ãããæ £ããªããã¨ãå¤ã ããã¾ãããã Youtubeçµç±ã®æ¹ãé ä¿¡ã®æ åãé³è³ªãªã©ã®ã¯ãªãªãã£ãé«ããããã£ãã®ã§ã¯ãªããã¨æãã¾ãã ã¤ãã³ãã«ã¯124åã®æ¹ã«ç³ãè¾¼ã¿ãããã¾ããï¼ ã¾ããyoutubeã§ã®æ大åææ¥ç¶æ°ã¯143ã«ãªã£ãã®ã§ãã¾ãã¾ãå¤ãã®æ¹ã«åå ããã ããã®ã§ã¯ãªãããªã¨æãã¾ãã ã¢ã³ã±ã¼ãçµæ ã¤ãã³ãã®åå ç»é²æã«ä¸è¨ã¢ã³ã±ã¼ããã¨ãã¾ãããããããã®çµæã«ã¤ãã¦å ±æãã¾ãã Embulkã¨Digdagã®ã©ã¡ãã«ä¸»ã«èå³ããã£ã¦åå ããã¾ããï¼ Embulkã¨Digdagãæ¬çªç°å¢ã«ã¦éç¨ãã¦ãã¾ããï¼
ãã¼ã¿ãã¼ã¹ã使ã£ã¦ä½ãããéã«ãããã¼ãã¼ã¿ãè¶ å¤§éã«æ¬²ãããªããã¨ãããã®ã§embulkã®input-pluginãä½ã£ã¦ã¿ãã githubã®ãªã³ã¯ ä½ããªãç°å¢ãããªã $ wget https://bintray.com/artifact/download/embulk/maven/embulk-0.2.1.jar -O embulk.jar ã§embulkæ¬ä½ã®ãéã£ã¦ããã®ã§ããã使ã£ã¦ $ java -jar embulk.jar gem install embulk-plugin-input-random ã¨ããã°ãã©ã°ã¤ã³ãéã£ã¦ããã exec: {} in: type: random rows: 100 schema: id: primary_key name: string score: integer out: type: stdout ãããªæãã®config
ããã«ã¡ã¯ãããã¯ã¨ã³ãã¨ã³ã¸ãã¢ã®å¡©å´ã§ãã å æ¥ãä¼ç¤¾ã®åºå ±ã®ããã®ã¤ã³ã¿ã¼ã³çç´¹ä»è¨äºã«ã¡ã³ã¿ã¼ã¨ãã¦æ²è¼ãã¦ããã ãã¾ããã 大å¦åå¹´çã®ã¤ã³ã¿ã¼ã³çã¨ä¸ç·ã«åçæ®å½±ãè¡ã£ãã®ã§ãããè¦ãç®ã ãã§ã¯ã©ã¡ããå¹´ä¸ãããããªãã£ãã®ã§ããã¡ã³ã¿ã¼ã®å¡©å´ï¼å³ï¼ãã¨ãã表è¨ãããã¦ãã¾ãã¾ããï¼ç¬ï¼ ã¤ã³ã¿ã¼ã³ã§ãå®éã®ãµã¼ãã¹ã«è§¦ãã課é¡ã解決ï¼ãVASILY DEVELOPERS BLOGãå ¬éããã¾ããã ãã¦ãVASILYã§ã¯Data Warehouseã¨ãã¦Google BigQueryï¼BigQueryï¼ãå©ç¨ãã¦ãã¾ãã BigQueryå ã«ã¯ãããã¯ãã®ãã¹ã¿ãã¼ã¿ã¨ã¦ã¼ã¶ã¼ã®è¡åãã°ãæ ¼ç´ããã¦ãã¾ãã ããã¦ããããã«å¯¾ãã横æçãªã¯ã¨ãªãçºè¡ãããã¨ã§ãããã¯ãã®æé·ã®ããã®KPIãã¢ãã¿ãªã³ã°ãã¦ãã¾ãã ãã®ããAmazon Relational Database
Rubyã®Procã®èª¬æã¯å··ã«æº¢ãã¦ããããä»æ´æããããã©ããæ°åProcã使ã£ããã¿ãæ¸ãã¦ãããProcããããããªã£ã¡ãã£ã¦ãã£ã¨ã¿ããªã«ãProcã®ãã¨ç¥ã£ã¦ãããããã¨ãã欲æ±ãçã¾ãã¦ããããProcã«ã¤ãã¦ã®åºæ¬çãªãã¨ãåãªãã®ããæ¹ã§ããã«æ¸ãããé·ããã Rubyã®é¢æ°ï¼ã¡ã½ããï¼ Rubyã«ããã¦é¢æ°ï¼ã¡ã½ããï¼ã¯ãã¡ã¼ã¹ãã¯ã©ã¹ï¼ãªãã¸ã§ã¯ãï¼ã§ã¯ããã¾ãããã¤ã¾ãæååãæ°åãé åãªã©ã®ä»ã®ãªãã¸ã§ã¯ãã¨ã¯ç°ãªã£ã¦ãRubyã§ã¯ãããç´æ¥å¤æ°ã«ä»£å ¥ããããä»ã®é¢æ°ã«æ¸¡ããããããã¨ã¯ã§ãã¾ããã def square(n) n * n end sq = square # squareã¡ã½ãããå¤æ°sqã«ä»£å ¥ãã¦ã¿ã # ~> -:1:in `square': wrong number of arguments (0 for 1) (ArgumentError)
詳細 https://techplay.jp/event/669346 0:01:10 TreasureDataã®ã¨ã³ã·ã¹ãã ã§ä½ãããã¹ããªETLãã¼ã¿å¦çåºç¤ã®ã¤ãããã 0:43:13 ãªã¤ã·ãã¯ã¹ã«ããããã¼ã¿åºç¤åæ§ç¯ã¨æ´»ç¨äºä¾ 1:39:45 AudienceOneã«ãããTreasureDataæ´»ç¨æ¹æ³ 2:09:39 TDã§è¦ãä»ã¨ææ¥
ã¯ããã¾ãã¦ãZucks Affiliateã§ã¨ã³ã¸ãã¢ããã¦ããå®å²¡ã§ãã ä»åã¯ããªã¢ã«ã¿ã¤ã æ§ã¯æ±ããªããã©ãç°¡åã«å¤§éã®ãã¼ã¿ãã©ããå¥ã®å ´æã«è»¢éãããã ã¨ããè¦æã«çãã¦ãããEmbulkãç´¹ä»ãããã¨æãã¾ãã å®éã«å°å ¥ã«è³ã£ããã£ããããéç¨ä¸ãããã課é¡ãªã©ã触ãã¦ããããã¨æãã¾ãã åãå¢éã®äººããç°¡åããã ãEmbulk使ã£ã¦ã¿ããããªãã¨ãªã£ã¦ããã ããã°å¹¸ãã§ãã ç®æ¬¡ ç®æ¬¡ èæ¯ Embulk以å¤ã«ãåºã¦ããæ¡ å®éã®Embulkã®å°å ¥ã¨ä½¿ãæ¹ 1. Embulkã®ã¤ã³ã¹ãã¼ã«ã¨ã»ããã¢ãã 2. å¿ è¦ãªãã©ã°ã¤ã³ã®ã¤ã³ã¹ãã¼ã« 3. è¨å®ãã¡ã¤ã«ãæ¸ã å®åã§codecommitã使ã£ãä¾ è¨å®ãã¡ã¤ã«ã®æ¸ãæ¹ 4. ã¾ãã¯previewã§åé¡ãªããããç¢ºèª 5. åé¡ãªããããªã®ã§runãã¦å®è¡ Embulkã®éç¨ä¸ãããã¶ã¤ããèª²é¡ 1. éè¤ã«æ°ä»
ã³ãã³ã:ãã®ç´å¾ã®ç©ºç½ã¯å¿ é ã®ããã ã[2015-10-31] è¡é ã«ãã¤ãã³ã-ããããã®ã¯ãé åï¼ã®åè¦ç´ ï¼ã å¤ã®ãªã¹ãï¼ä¸è¦§ï¼ãè¨è¿°ãããã®ã®ããã ã ä¸è¡ã§è¨è¼ãããå ´åã¯è§æ¬å¼§ã§å²ãã[2015-10-31] è§æ¬å¼§ã§å²ãæ¹æ³ è¤æ°è¡ã«åãã¦è¨è¿°ããæ¹æ³ Embulkã®YAMLãã¡ã¤ã«ã®æ§é Embulkã®YAMLãã¡ã¤ã«ï¼ããconfig.ymlã¨ãããã¡ã¤ã«åã§ä¾ãæãããã¦ããï¼ã ã¨ãã¾ãããã¼ããinãããoutãã¨ãªã£ã¦ããããã·ã¥ãæå®ããã config.ymlï¼ in: ï½ out: ï½ inãoutã®å¤ã¯ããã«ããã·ã¥ãªã®ã§ãæ³¢æ¬å¼§ã§å²ãã ãããã¯ã«ãã¦ãããã ããããæ°ãå¤ãã®ã§ãè¤æ°è¡ã«åãã¦è¨è¿°ãã¦ããã®ã ããã è¤æ°è¡ã«ããå ´åã¯ãã¤ã³ãã³ããå¢ãããåè¡ã®ã¤ã³ãã³ãï¼æ¡ä½ç½®ï¼ã¯çµ±ä¸ããã config.ymlï¼ in: {type: file, p
1. Sadayuki Furuhashi Founder & Software Architect Treasure Data, inc. EmbulkAn open-source plugin-based parallel bulk data loader that makes painful data integration work relaxed. Sharing our knowledge on RubyGems to manage arbitrary ï¬les. 2. A little about me... > Sadayuki Furuhashi > github/twitter: @frsyuki > Treasure Data, Inc. > Founder & Software Architect > Open-source hacker > MessagePack
0.ã¯ããã« ãã¡ãã¯re:dash Advent Calendar 2016ã®22æ¥ç®ã®è¨äºã§ãã Advent Calendarã«ã¤ãã¦åºé ããã¨æã£ã¦ããã¨ããããã ãã¡ãã¯ã¾ã 空ãæ ãããã¾ããã®ã§åå ãã¾ããã Macä¸ã§ä»¥ä¸ã®ãããªæã㧠CSVãã¡ã¤ã«ã digdag -> embulk ->ã(Re:dashã®)PostgreSQLã¸æ ¼ç´ãã¦Reï¼dashããè¦ãã¨ããã¾ã§ãè¨äºã«ãã¾ãã ãã¢ãç´ æ¯ãç¨ãªã©ã®åèã«ãã¦é ããã°ã¨æãã¾ãã 以ä¸ã¯ä»åæ¬è¨äºã§ã¯åãæ±ãã¾ããã以åæ¸ãã¾ãããã¡ãã®è¨äºãããã¡ãã®è¨äºãåèã«å¿ç¨ããã¨ChatOpsçãªæãã§ãã¼ã¿ç»é²ãå¯è½ã§ãã 1.ç°å¢ OSX Yosemite Docker version 1.13.0-rc3, build 4d92237 docker-compose version 1.9.0, build 2
ããã«ã¡ã¯ãæè¿Embulkï¼ã¨ã³ãã«ã¯ï¼ã調ã¹ã¦ããå·å´ã§ãã ã¿ã¤ãã«ã®ãDigDagãï¼ãã£ã°ãã°ï¼ *1ã¨èãã¦âã¡ãã³ã³ãâã ã³ãæãæµ®ãã¹ãæ¹ã¯ãã£ã¨ã¢ã©ãµã¼ä»¥ä¸ã§ããï¼ ä»åã¯Embulkã使ãå§ããã¨ç´é¢ããã§ããã課é¡ã«ã¤ãã¦æ¸ãã¦ããããã¨æãã¾ãã ããã¾ã§ã«æ¸ããEmbulkã¨ã³ããªã¼ [Embulk] Embulkã«ã¤ãã¦ã®å人çãªã¾ã¨ã [Embulk] guessæ©è½ã試ãã¦ã¿ãã追è¨ããã [Embulk] guessæ©è½ã試ãã¦ã¿ã Redshiftç·¨ [Embulk] ã¿ã¤ã ã¹ã¿ã³ãã®ã«ã©ã ã追å ãã [Embulk] ã¿ã¤ã ã¹ã¿ã³ãã®ã«ã©ã ã追å ãã add_timeãã©ã°ã¤ã³ç·¨ [Embulk] guessæ©è½ã試ãã¦ã¿ã (ãã¼ãã«ãåå¨ããå ´å) Embulkã使ãã¯ãããã¨... Embulkã¯ãã¼ã¿ãã¡ã¤ã«ã®ä¸èº«ãDBã«ãã¼ããããããªç¨éã§
2. WHO AM I ? ⢠Toru Takahashi (@nora96o) ⢠Treasure Data, Inc. ⢠Support Engineering Manager ⢠ã¡ã¼ã«ã«ãã£ããã«ãããã°æ¸ããããã³ã¼ããæ¸ãããã ⢠http://qiita.com/toru-takahashi ⢠æ°ã¥ãã¨ã社ä¼äººï¼å¹´ç®ã«çªå ¥ã»ã»ã» 2 3. 質åã§ãï¼ â¢ Treasure Data ã ç¥ã£ã¦ããäººã¯ ï¼ â¢ Fluentd ã ç¥ã£ã¦ããäººã¯ ï¼ â¢ Embulkãç¥ã£ã¦ãã人ã¯ï¼ ⢠Digdagãèãããã¨ããã人ã¯ï¼ ⢠ã¤ã³ãã© / åæåºç¤ ãæ®æ®µããéç¨ãéçºããã¦ãã人ã¯ï¼ ⢠iOS / Android / Unity / ããã³ãã¨ã³ãã®äººã¯ï¼ 3
Built-in Plugins Configuration Embulk configuration file format Local file input plugin CSV parser plugin JSON parser plugin Gzip decoder plugin BZip2 decoder plugin File output plugin CSV formatter plugin Gzip encoder plugin BZip2 encoder plugin Rename filter plugin Remove columns filter plugin Local executor plugin Guess executor Preview executor Logo Images Logo Square Horizontal Icon Customiza
ããã«ã¡ã¯ãå¤æ©ã§ãã å æ¥ã®*1 ãã¼ã¿è»¢éããã«ã¦ã§ã¢åå¼·ä¼ã§ãæ°ãããªã¼ãã³ã½ã¼ã¹ãã¼ã« Embulk ããªãªã¼ã¹ãã¾ããã Embulk, an open-source plugin-based parallel bulk data loader from Sadayuki Furuhashi Embulk ã¯ããªã¢ã«ã¿ã¤ã ãªãã°åéã§ã¯å¸¸èã¨ãªã£ã fluentd ã®ãããçã®ãããªãã¼ã«ã§ããã¡ã¤ã«ããã¼ã¿ãã¼ã¹ãããã¼ã¿ãå¸ãåºããå¥ã®ã¹ãã¬ã¼ã¸ããã¼ã¿ãã¼ã¹ã«ãã¼ãããããã®ã³ã³ãã¯ããªãã¼ã«ã§ãã fluentd ã¨åæ§ã«ãã©ã°ã¤ã³åã®ã¢ã¼ããã¯ãã£ãæ¡ç¨ ãã¦ãããããRubyãJavaã§ç°¡åãªã³ã¼ããæ¸ããã¨ã§ãæ§ã ãªãã¡ã¤ã«ãã©ã¼ããããã¹ãã¬ã¼ã¸ã«å¯¾å¿ãããã¨ãã§ãã¾ããä¸æ¹ã§ fluentd ã¨ã¯ç°ãªããé«éæ§ããã©ã³ã¶ã¯ã·ã§ã³å¶å¾¡ãã¹ãã¼ãã使ã£ããã¼ã¿ã®ããª
ãç¥ãã
ã©ã³ãã³ã°
ã©ã³ãã³ã°
ãªãªã¼ã¹ãé害æ å ±ãªã©ã®ãµã¼ãã¹ã®ãç¥ãã
ææ°ã®äººæ°ã¨ã³ããªã¼ã®é ä¿¡
å¦çãå®è¡ä¸ã§ã
j次ã®ããã¯ãã¼ã¯
kåã®ããã¯ãã¼ã¯
lãã¨ã§èªã
eã³ã¡ã³ãä¸è¦§ãéã
oãã¼ã¸ãéã
{{#tags}}- {{label}}
{{/tags}}