분류 전체보기 (74) 썸네일형 리스트형 2025년 1월 ~ 3월 회고 벌써 2025년의 1분기가 지나고, 새로운 2분기로 나아가고 있습니다 차가운 겨울은 다음을 기약하며 물러가고 싱그러운 봄이 찾아와 벚꽃이 만개하며 그 풍경처럼 저의 마음 또한 새롭게 물들고 있는 듯 해 설레는 기분입니다 돌이켜 보니, 저는 겨울을 만나고 안녕을 기약하며 1분기 동안 어떤 시간을 보냈을까요? 1. 바쁜? 회사생활 조직 속에서 시간을 보내며,제 단점들이 하나둘씩 보이기 시작했습니다.그동안 몰랐던 저의 행동들이, 문득문득 드러났습니다. 혼자서 일하는 데 익숙했던 저는,지나치게 자기 주도적으로 일을 처리했고—성과를 빨리 내고 싶은 마음에조직에 적응하는 것보다 앞서나가려는 자세를 보이곤 했습니다. 하지만 모든 조직에는 ‘처리’와 ‘순서’가 있다는 걸,저는 간과하고 있었습니다.조직을 .. 2024년 12월 회고 (2024년의 마침을 준비하면서) 10월 의 회고가 끝난 지가 엊그제 같은데 벌써 2024년의 마무리를 하기 위해서 준비를 하고 있는 제가 보입니다 2024년 의 마무리를 준비하고 지난날들의 회상하며 추억의 키워드를 말해보며 2024년의 마무리를 장식해보려고 합니다 저는 2024년을 어떻게 보냈을까요? 저는 이거 하나는 말할 수 있을 거 같습니다 저는 항상 최선을 다했습니다 1. 창업 1.1 저는 더 나은 삶을 살고 싶었습니다.사람들과 함께 발전하고, 함께 웃으며 기쁨을 나눌 수 있는 삶을 꿈꿨습니다.사회에 발자국을 남기며, 제가 뿌린 작은 영향들이 긍정적인 효과로 이어지길 바랐습니다. 1.2 목소리를 내고, 조직을 이끌며, 사람들과 함께 나아가는 삶.저는 대표가 되어, “나도 할 수 있다”는 믿음과 “우리 모두 할 수 있다”는 확신을.. 다시 돌아온 코인 프로젝트 (2) 스토리가 계속 이어집니다 이전 편을 보고 오시면 더욱 이해가 좋습니다! https://sky-develop.tistory.com/99 다시 돌아온 코인 프로젝트 (1)스토리가 계속 이어집니다 이전 편을 보고 오시면 더욱 이해가 좋습니다! https://sky-develop.tistory.com/98 다시 돌아온 코인 프로젝트 (0)오랜만에 포슽잉 이예요 리프레쉬 이후 다시 씽나게 저의 목sky-develop.tistory.com 다시 한번 가보시죠! kafka로 전송로 전처리 한 데이터를 다시 생성해서 보내고 나서 spark-streaming으로 처리 분석을 시작하였습니다 이때 제가 원했던 처리 분석은 다음과 같아요 Ticker 거래 분석 1. 거래소별 평균 2. 지역별 평균 3. 지역 간 .. 다시 돌아온 코인 프로젝트 (1) 스토리가 계속 이어집니다 이전 편을 보고 오시면 더욱 이해가 좋습니다! https://sky-develop.tistory.com/98 다시 돌아온 코인 프로젝트 (0)오랜만에 포슽잉 이예요 리프레쉬 이후 다시 씽나게 저의 목적을 향해 다시 글을 써보려고 합니다 완성은 한 상태이고 하나하나 차근차근 복기를 해보며 지나가려고 합니다 거래소 선택 sky-develop.tistory.com 커넥션을 연결하여 저는 각 스키마 마다 다음과 같이 모든 거래소에서 뽑았습니다..!!timestamp타임스탬프opening_price시가trade_price현재가high_price고가low_price저가prev_closing_price지난 종가acc_trade_volume_24h24시간 평균 볼륨signed_change_.. 다시 돌아온 코인 프로젝트 (0) 오랜만에 포슽잉 이예요 리프레쉬 이후 다시 씽나게 저의 목적을 향해 다시 글을 써보려고 합니다 완성은 한 상태이고 하나하나 차근차근 복기를 해보며 지나가려고 합니다 거래소 선택 거래소를 기존 4개에서 9개로 늘렸습니다 이유는 스케일을 늘려 우리나라 와 다른 지역 간의 거래소 가격차이가 얼마나 나는지 지역 간 거래를 할 때 어떤 거래소에서 진행해야 수익이 나는지를 관찰하고 싶었습니다대한민국업비트빗썸코빗코인원 아시아OKXBybitGateIO유럽BinanceKraken 어떻게 진행했을까?websocket으로 Ticker와 Orderbook으로 진행하였습니다 도중에 끊기면 rest api로 호출하도록 만들었어요 Ticker -> 현재가, Orderbook -> 거래 영수증(어떤 가격에 얼마나 사고팔았는.. 2024년 3월 ~ 10월 회고 이제야 회고를 쓰게 되었네요. 2024년도 얼마 남지 않았고, 참 많은 일들이 지나갔네요올해가 과연 좋았던 걸까요, 아니면 그렇지 못했을까요? 한 가지 분명한 것은 매일의 나는 최선을 다했다 라는 점 인거 같습니다 저는 ‘인간은 내일이 있기에 더 나은 사람이 될 수 있는 존재’라고 믿고 있습니다. 그런 점에서 올해는 제게 두 가지 큰 타이틀로 남았습니다창업과 취업에서의 도전 그리고 나 자신에 대한 성찰입니다. 1. 창업과 취업으로서 - 창업에 계속 도전하며 다양한 사람들을 만나고 여러 경험을 쌓아가며, 내 조직을 꾸려 함께 세상을 향해 나아가고 싶다는 열망이 있었습니다. 창업을 통해 저는 자문했습니다. “내가 진정 바라는 세상은 어떤 모습일까?” 그리고 사회적으로 기여하는 기업이 실제로 어떻게 움직이고 .. aiokafka.errors.IllegalStateError: IllegalStateError: Subscription to topics, partitions and pattern are mutually exclusive 발생 경위: consumer에서 특정 partition을 소모하려고 할때 발생 코드는 다음과 같다 @handle_kafka_errors async def initialize(self) -> None: """Kafka 소비자 및 생산자 연결 초기화""" if self.consumer_topic: self.consumer = AIOKafkaConsumer( self.conuser_topic, bootstrap_servers=self.bootstrap_servers, group_id=self.group_id, auto_offset_reset="lates.. TypeError: 'ThreadPoolExecutor' object does not support the asynchronous context manager protocol 발생 경위 : 비동기 함수에 ThreadPool 올림# fmt: offasync def coin_present_websocket(connection_class: connection) -> None: """두 개의 코인 웹소켓을 동시에 실행.""" async with ThreadPoolExecutor(max_workers=2) as executor: loop = asyncio.get_running_loop() # 클라이언트 클래스를 매개변수로 전달하여 작업 실행 korea_task = loop.run_in_executor( executor, asyncio.run, run_coin_websocket(connection_class, "BTC.. 이전 1 2 3 4 ··· 10 다음
