HAMA 블로그

* 참고로 커링이 무엇인가요에 대한 대답은 너무 쉽다. 하지만 왜 커링이 그렇게 유용하나요? 에 대한 대답은 아직 못얻었다. 뇌 로는 알겠지만 체득하지 못한 상태. 스칼라를 함수형 파라다임으로 사용을 많이 해봐야 알게 되지 않을까.. 스칼라에서의 커링 (currying) 1. 개념 스칼라 Doc 에서는 이렇게 말합니다. (http://docs.scala-lang.org/ko/tutorials/tour/currying)메소드에는 파라미터 목록을 여럿 정의할 수 있다. 파라미터 목록의 수 보다 적은 파라미터로 메소드가 호출되면, 해당 함수는 누락된 파라미터 목록을 인수로 받는 새로운 함수를 만든다.중요한 포인트를 뽑아내어 쉽게 설명해보면 매우 쉬운 설명 - 메소드라는건 파라미터를 가지고 있지요? 예를들어 a..

- https://github.com/enshahar/BasicFPinScala/blob/master/Intermediate/Monad.md- https://github.com/enshahar/BasicFPinScala/blob/master/Intermediate/Monad_Rules.md - Monad Programming with Scala Future- http://www.haruair.com/blog/2986- http://blog.seulgi.kim/2015/07/what-is-monad.html- 자바언어로 서술한 Functor 와 모나드 제 능력이 부족한 관계로 위의 글로써 대신합니다. (모나드 관련 한글 블로그 모음) 아참! 위의 글을 읽기 전에 반드시 모나드 괴담!을 읽어보세요. ^^ 모..

- Scala 2.11.8 기반 - Akka 2.4.11 기반 - Java 8 (akka 2.4 부터는 java 8 요구함. scala 2.11 은 java 7도 괜찮지만~) 하나의 ActorSystem에 IO,Remote 등 사용내가 만들고 있는 마이크로 서비스 타입의 시스템에서는 들어오는 메세지에 대해 각자 다르게 처리하기 (다른 목적지로 배달해주는)위한 커뮤니케이션 모듈이 있는데 (이름은 룰엔진이며 아이디어는 AWS IoT 에서 따왔다) 대략 아래 처럼 구성되어 있다. 단일 액터 시스템 내에 슈퍼바이저 액터라는 가장 부모 액터가 나머지 액터를 관리하고 그 중 룰엔진 액터가 나머지 액터들의 메세지를 커뮤니케이션 된다. Akka.tcp 가 이종간 통신을 위해 사용되며 원격 액터시스템 끼리는 akka.r..

- Scala 2.11.8 기반 - Akka 2.4.11 기반 - Java 8 (akka 2.4 부터는 java 8 요구함. scala 2.11 은 java 7도 괜찮지만~) 여러개의 ActorSystem 사용 하나의 호스트에서 액터시스템 여러개를 사용하는것에 관해 생각해보면 관심사의 분리라고 해야하나? 액터군도 여러개가 될 수 도 있을 것이다. 따라서 액터시스템도 그에 맞게 여러개를 사용 할 수 도 있다. (Play2 에 내 자신의 액터시스템을 임베디드 시키는것도 마찬가지) 이 부분에 대해서는 아직 나도 정확하게 이렇게 해야한다라고 말하기 어렵기 때문에 사실만 짚고 넘어가자면 액터 시스템 사이의 통신은 안된다. 이게 가능하려면 둘을 remote 로 연결해야 한다. 그리고 많은 수의 액터 시스템을 하나의..

InfluxDB 와 Grafana 를 사용하는 방법은 아래 링크를 통해 알 수 있다. http://hamait.tistory.com/537 이 둘을 같이 쓰다보면 시간때문에 헥깔릴 수 있는데 간단 정리 해본다.A 기기 : InfluxDB 에 데이터를 넣는 머신 ( OS시간 1시 30분 ) DB 서버 : InfluxDB 가 돌아가는 서버 ( OS 시간 1시 ) 내 PC : 브라우저를 (Grafana) 통해 가시화하는 내 컴퓨터 (OS 시간 12시 30분) 가 있다고 하자.A 기기에서 InfluxDB 서버에 현재 시간 1시 30분을 UTC 시간으로 변경하여 데이터와 함께 INSERT 해주면 InfluxDB 에 저장된다.이때 내 PC, 즉 내 브라우저 통해서는 어떻게 데이터가 나올까? 내 컴퓨터에선 안나온다...

- Scala 2.11.8 기반 - Akka 2.4.11 기반 - Java 8 (akka 2.4 부터는 java 8 요구함. scala 2.11 은 java 7도 괜찮지만~) 참고 : http://queirozf.com/entries/scala-slick-simple-example-on-connecting-to-a-postgresql-database http://slick.lightbend.com/doc/2.1.0/sql-to-slick.html#insert https://github.com/lucperkins/spray-akka-slick-postgresAkka 에서 PostgreSQL 사용하기1. Scala 로 PostgreSQL 사용하기 (with Slick) 의존성 추가 libraryDepende..

Python 의 simplejson 사용하기 의존성 추가 import simplejson 문자열로 JSON 형태 만들기 szJson = '{' + '"callid":{}, "nodeid": {}, "content":"{}"'.format(1, 1, "hello") + '}' 이렇게 { "key" : "value"} 식으로 만들 수 있다.출력해보면 아래와 같다.print szJson # {"callid":1, "nodeid": 1, "content":"hello world"}print type(szJson) # 문자열 JSON 형태를 JSON Object (사전타입) 로 만들기 jsonObj = simplejson.loads(szJson) 출력해보면 아래와 같다. Dictionary (사전) 타입이 되었다..

https://eng.uber.com/mysql-migration/ 나중에 읽어보자.!! 반박 및 논쟁글은 여기 => https://news.ycombinator.com/item?id=12166585 ConclusionPostgres served us well in the early days of Uber, but we ran into significant problems scaling Postgres with our growth. Today, we have some legacy Postgres instances, but the bulk of our databases are either built on top of MySQL (typically using our Schemaless layer) or, i..

- Scala 2.11.8 기반 - Akka 2.4.11 기반 - Java 8 (akka 2.4 부터는 java 8 요구함. scala 2.11 은 java 7도 괜찮지만~) Akka TCP 와 데이터의 끝 서론 Akka TCP 서버를 만들때 데이터를 받는 부분의 대부분의 예는 그냥 Received(data) 이다. 즉 아래 형태.def writing: Receive = { case Received(data) => log.info(s"fromGW - '${data.utf8String}'") ruleEngine ! fromTGH(data.utf8String) data 는 ByteString 형 이기 때문에 Json문자열을 보낼 경우 utf8String 으로 변경해서 처리하는데 여기서 문제가 하나 있다. 다..

스칼라에서 JSON 데이터 다루기* scala 기존제공하는것보다 json4s 나 spray-json 이 더 나은듯하다. 1. 디펜던시 추가 import scala.util.parsing.json._ 2. 문자열에서 Json 객체 (Map 타입) 로 변경 - (1) def main(arg : Array[String]): Unit ={ val result = JSON.parseFull(""" {"name": "Naoki", "lang": ["Java", "Scala"]} """) result match { case Some(e) => println(e) case None => println("Failed.") } } //print 결과 : Map(name -> Naoki, lang -> List(Java, ..