분류 전체보기 (73) 썸네일형 리스트형 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.. RuntimeError: There is no current event loop in thread 'ThreadPoolExecutor-1_0'. 발생 경위 : 비동기 함수 3개와 함께 다음과 같이 실행 시 발생하였음 async def crawl_and_insert(target: str, count: int, driver_class, source: str) -> None: loop = asyncio.get_running_loop() with ThreadPoolExecutor(max_workers=3) as executor: # run_in_executor를 통해 크롤링을 비동기적으로 실행 data_list = await loop.run_in_executor( executor, lambda: driver_class(target=target, count=count).news_collector() .. 이전 1 2 3 4 ··· 10 다음
