๐ปTech160 [๋ฆฌ๋ ์ค] ์๋ฒ Asia/Seoul ํ์์กด ์ ์ฉ timedatectl set-timezone Asia/Seoul 2022. 11. 3. [NiFi] content ๋ด์ฉ์ attribute๋ก ์ ์ฅํ๋ ๋ฐฉ๋ฒ NiFi Processor ์ค ExtractText ํ๋ก์ธ์์์ ์ ๊ท์์ ์ฌ์ฉํ๋ฉด ๋ฉ๋๋ค. html ๋ด์ฉ์ attribute์ ์ ์ฅํด์ sql์ ์ง์ด๋ฃ๊ธฐ ์ํด ์ถ์ถํ์ต๋๋ค. ๐จ๐ป ExtractText์์ ๋ณ๊ฒฝํ properties ๋ด์ฉ Maximum Capture Group Length = 1048576 Enable DOTALL Mode = true Enable Multiline Mode = true body = (.*) 2022. 10. 20. [NiFi] ORACLE, Impala Data Type ๋น๊ต NiFI์์ ORACLE ๋ฐ์ดํฐ ์์งํ ๋ ์ ๋ฆฌํ ๋ด์ฉ์ ๋๋ค. ๐ Data Type ORACLE Impala CLOB string varchar string number(int) decimal(20,0) number(double) decimal(20,3) timestamp timestamp date timestamp binary_double double โพ ExecuteSQLRecord Use Avro Logical Types: true Max Rows Per Flow File: 500000 Fetch Size: 500000 โพ Impala DBCP Validation query: select 1 2022. 9. 22. [NiFi] Groovy-Java๋ก ์ฌ๋ฌ ๋ ์ง ๋ฝ๋ ๋ฐฉ๋ฒ NiFi์์ ์ ๊ณตํ๋ Groovy Script๋ ์๋ฐ ํธํ์ด ๊ฑฐ์ ๋๋ฏ๋ก ์๋ฐ ์ฝ๋๋ก ์์ฑํ์ฌ๋ ์ ๋์๊ฐ Create ExecuteScript Processor PROPERTIES > Select Groovy > Write Script Body Script Contents import java.text.DateFormat; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Date; //attribute์ ๋ ์ง(yyyymmdd) ๊ธฐ์ค๋ถํฐ -30์ผ๊น์ง ์ถ์ถ flowFile = session.get(); if(!flowFile) return; dt = flo.. 2022. 9. 22. zeppelin interpreter resource share mode (notebook pending) zeppelin ์์ ์ฌ๋ฌ ํ์คํฌ๋ฅผ ์คํํ๋ฉด, ์ ํ ์์ ์ด ๋๋ ๋๊น์ง ์์ ์ด pending ๊ฑธ๋ฆฌ๋ ๊ฒฝ์ฐ๊ฐ ์๋ค์ ๐ ๋งํฌ ์ฐธ๊ณ https://zeppelin.apache.org/docs/0.8.0/usage/interpreter/interpreter_binding_mode.html 2022. 9. 19. [NiFi] global variable(์ ์ญ๋ณ์) ์ค์ nifi์์ global variable(์ ์ญ๋ณ์) ์ค์ ํ์ฌ ์ฌ๋ฌ Process Group์์ ํ์ฌ ๋ ์ง(yyyyMMdd)๋ฅผ ์ฌ์ฉํ๋ ์๊ฑด์ด ์์๋๋ฐ ๋ฐฉ๋ฒ ์ฐพ๋๋ผ ์์ฒญ ๊ณ ์ํ๋ค์ ๐ญ Variables์ Parameter 2๊ฐ์ง ๊ธฐ๋ฅ์ ์ ๊ณตํ๋๋ฐ Parameter์์ NiFi EL(Expression Language)์ด ๋จนํ์ ๊ธ๋ก๋ฒ ๋ ์ง ๋ณ์๋ฅผ ์ถ์ถํ ์ ์์์ต๋๋ค. Variables์์๋ ${now():format('yyyyMMdd')} ์ ๊ฐ์ ํํ์์ ๋ชจ๋ String ๋ฌธ์ ๊ฐ์ผ๋ก ์ฝ์ด์ ๋ฐํํด์ ์ฌ์ฉํ ์ ์๊ณ , Parameter๋ EL ํํ์์ด ์ฌ์ฉ ๋ถ๊ฐํ๋ค๊ณ NiFi doc์ ๋์์์ง๋ง ์ฌ์ฉ์ด ๋๋ค์..๐คจ 1. Parameter์์ EL ์ฌ์ฉ ๋ฐฉ๋ฒ์ ๋๋ค. 2. ํ๋ก์ธ์ค ๊ทธ๋ฃน์ ํ๋ผ๋ฏธํฐ ๋งคํ 3.. 2022. 8. 31. [zeppelin] python interpreter ์ค์น ๋ฐ ์ฐ๋ ํด๋ผ์ฐ๋ฐ๋ผ์์ zeppelin ์๋น์ค์ python interpreter ์ค์น ๋ฐ ์ฐ๋ํ๋ ๋ฐฉ๋ฒ์ ๋๋ค. clouder doc์๋ ๋์์์ง ์์ ๊ณผ๊ฑฐ HDP์ Apache Zeppelin ๋ฌธ์ ์ฐธ๊ณ ํ์์ต๋๋ค ๐ 1. zeppelin ์ค์น๋ ์๋ฒ ์ ์ ํ ํ์ด์ฌ ์ธํฐํ๋ฆฌํฐ ์ค์น ์ค์น ์๋ฃ๋๋ฉด /opt/cloudera/parcels/CDH/lib/zeppelin/interpreter/python ๊ฒฝ๋ก๊ฐ ์์ฑ๋จ ํ์ ๊ฒฝ๋ก ๊ถํ ํ์ธ (chmod 644) /opt/cloudera/parcels/CDH/lib/zeppelin/bin/install-interpreter.sh -n python 2. zeppelin web-ui > interpreter > create python interpreter๊ฐ ์ ์ ์ค์น๋๋ฉด.. 2022. 8. 18. [zeppelin] Authentication failed for PAM. ๐ซ ERROR Exception in login: org.apache.shiro.authc.AuthenticationException: Authentication failed for PAM. Caused by: org.jvnet.libpam.PAMException: pam_authenticate failed : Authentication failure ๐ก SOLVED ## check shiro.ini: -------------------------------------------- pamRealm=org.apache.zeppelin.realm.PamRealm pamRealm.service=sshd -------------------------------------------- ## set acl $ se.. 2022. 8. 16. ์ด์ 1 2 3 4 5 6 7 ยทยทยท 20 ๋ค์