분류 전체보기 (49) 썸네일형 리스트형 [Apache Kafka] 설치 & 실행 & 명령어 0. 설치 Apache Kafka 사이트에 가서 파일을 다운받습니다. kafka.apache.org/downloads Apache Kafka Apache Kafka: A Distributed Streaming Platform. kafka.apache.org 저는 스칼라 버전 2.12 를 사용하겠습니다. Download file : kafka_2.12-2.7.0.tgz 압축을 풀어줍니다. tar -xvf kafka_2.12-2.7.0.tgz 기본기능만 테스트 할 예정이니 설정파일은 디폴트 값으로 쓰겠습니다. kafka 는 java가 있어야 실행이 됩니다. java 설치되어있지 않는경우 설치를 해주셔야 합니다. (java 8 이상) 1. Zookeeper 실행 ./bin/zookeeper-server-sta.. [Apache Flink] CEP-Complex Event Processing ○ CEP 란? 내용높은 빈도로 발생하면서 낮은 지연 시간을 요구하는 이벤트의 스트림을 분석합니다. CEP는 이벤트, 하위 이벤트 및 시쿼스의 스트림에서 패턴을 파악할 수 있습니다. 서로 관련이 없는 이벤트들 사이에서 의미 있는 패턴 및 복잡한 관계를 알아내고, 실시간으로 알림을 전송하는 등 대응을 통해 피해를 사전에 막을 수 있도록 해준다. ○ Flink CEP 라이브러리 주요 구성 요소 1. 이벤트 스트림 ( Event Stream ) 2. 패턴정의( Pattern definition ) 3. 패턴 추적( Pattren detection ) 4. 경보 조치 생성( Alert generation ) ● 이벤트 스트림 ( Event Stream ) 데이터를 입력받기 위한 이벤트 스트림을 이용하려면 이벤트.. [Apache Flink] DataStream API를 이용한 데이터 처리 ○ Apache Flink DataStream API 라이브러리 주요 구성 요소 1.실행환경 2.데이터 소스 3.데이터 트랜스포메이션 4.데이터 싱크 5.커넥터 ● 실행 환경 ( Execution Environment ) ▷ 실행환경 구분 - 기존 플링크 환경 입력 - 로컬 실행환경 생성 - 원격 실행환경 생성 보통 실행시 getExecutionEnviroment() 를 사용한다. 그럼 IDE의 로컬에서 실행 중인 경우 로컬실행환경이 시작되고, 아닐 경우 클러스터 관리자가 분산형태로 실행한다. 직접 구분하고 싶으면 로컬 환경은 createLocalEnvironment() 를 사용. 원격은 createRemoteEnvironment(String host, int port, String, jar파일 등) 사.. [Upbit] 자동매매 프로그램 (Python) #2 이전에 자동매매프로그램을 만들어보았습니다. https://bab-dev-study.tistory.com/8 [Upbit] 자동매매 프로그램 (Python) #1 ○ 준비작업 Upbit Open API 를 활용하여 자동매매 프로그램을 만들어 보겠습니다. 먼저 API를 사용하기 위해서는 Upbit 에 사용신청을 해야합니다. 참조 : wikidocs.net/31063 위키독스 온라인 책을 제작 bab-dev-study.tistory.com 현재 프로그램 하나에서 매수와 매도를 동시에 하는걸로 만들었는데 1분에 한번씩 조회를 하다보니 매도 타이밍을 놓치는 경우가 많았습니다. 그래서 이번엔 매도만 하는 프로그램으로 따로 분리하여 만들어보겠습니다. class Myupbit(pyupbit.Upbit) 생성 pyupb.. [Upbit] 자동매매 기록 #1 ○ 성공 단타로 성공한 기록입니다. 2021-03-20 08:59:35 [BUY] KRW-NPXS price: 6.6 unit: 121212.121212 2021-03-20 09:07:36 [sell_strategy_2] KRW-NPXS : 8.08 2021-03-20 09:07:37 [SELL] KRW-NPXS price: 8.08 unit: 121212.1212 => 6.6 > 8.08 , 22.42 % 원하는 대로 매수를 하고 매도가 되었습니다. 이렇게만 되면 참 좋을텐데 실패하는게 많습니다. ○ 실패 실패기록입니다. 2021-03-20 22:21:39 [buy_strategy_5] KRW-MED : 123.0 2021-03-20 22:21:39 [BUY] KRW-MED price: 123.0 un.. [Upbit] 자동매매 프로그램 (Python) #1 ○ 준비작업 Upbit Open API 를 활용하여 자동매매 프로그램을 만들어 보겠습니다. 먼저 API를 사용하기 위해서는 Upbit 에 사용신청을 해야합니다. 참조 : wikidocs.net/31063 위키독스 온라인 책을 제작 공유하는 플랫폼 서비스 wikidocs.net 이곳에 사용방법이 안내가 잘되어있으며 기본 사용법까지 설명이 나와있습니다. 이것을 활용하여 프로그램을 만들어보겠습니다. ○ define_argparser 함수 정의 먼저 실행시에 입력값을 받을 수 있도록 argparser를 만들겠습니다. import argparse def define_argparser(): p = argparse.ArgumentParser() p.add_argument( '--buyamount', required=.. [Apache Flink] 설치하기 (windows 10) Windows 10에서는 우분투 환경을 만들수있습니다. 이 내용은 나중에 포스팅을 할 예정입니다. Linux용 Windows 하위 시스템(WSL)을 설정하고 MS 스토어에서 "Ubuntu" 를 설치해서 환경을 준비합니다. 1. Java 설치 우분투 환경을 처음 설치하였으면 Java가 설치가 필요합니다. apt-get 업데이트도 필요합니다. sudo apt-get update sudo apt-get install openjdk-8-jdk 설치가 정상적으로 됬으면 확인을 해보자 > java -version openjdk version "1.8.0_282" OpenJDK Runtime Environment (build 1.8.0_282-8u282-b08-0ubuntu1~20.04-b08) OpenJDK 64-.. 주식정보 - 기초종합정보 확인 ( PER, EPS, PBR, BPS ) 주식 정보에 표시되는 기본적인 정보를 정리해 보겠습니다. 현재 네이버에서 주식정보를 누르면 나오는 정보입니다. 여기서 가격과 거래량, 배당금 항목은 이름만 들어도 감이 옵니다. 여기서 PER, EPS, PBR, BPS에 대해서 알아보겠습니다. EPS ( 주단순이익 : Earning Per Share ) EPS = 당기순이익 / 발행주식수 회사의 재무표를 보면 당기순이익 항목이 있습니다. 당기순이익이란? 기업이 일정기간동안 얻은 모든 수익에서 지출한 모든 비용을 공제하고 순수하게 남은 이익을 말합니다. 이 항목을 발행주식수로 나눈 결과는 기업이 1년동안 1주당 얼마의 이익을 벌었는지 알수있습니다. ( 현재 삼성전자의 EPS는 3,841원이며 이는 1년동안 벌어들인 수익이 1주당 3,841원이라는 것이다) .. 이전 1 ··· 3 4 5 6 7 다음
