이번에 알아볼 내용은 Dataframe의 Column 이름 변경을 해보도록 하겠습니다. 굉장히 많이 쓰이는 기능인데.. 저는 매번 바꿀 때마다 까먹어서 포스팅을 작성해서 기억에 좀 넣어보도록 하겠습니다. 이번에도 코드를 보며 진행해보도록 합니다. # Pandas 로딩 import pandas as pd # Dataframe 생성 df = pd.DataFrame({ 'a': [4, 5, 6], 'b': [7, 8, 9], 'c': [10, 11, 12]}, index = [1, 2, 3] ) # 첫번째 방법 df.columns = ["d", "e", "f"] df #두번째 방법 df.rename(columns = {'d' : 'a', 'e':'b', "f":"c"}, inplace = True) df 이렇..

이번 글에서는 파이썬의 예외처리 기능을 한번 적어본다. 우리가 코드를 실행할때 많은 에러가 발생하는데 이것을 우리가 넘겨도 되는 에러인지. 아닌지 혹은 에러가 발생한다면! 이라는 조건(분기)을 걸고 싶을 때 사용할 수 있다. 먼저 예제 코드부터 알아보자. # 리스트 생성 num_list = [1,2,3,4,5,6,7,8,9,10] for i in range(15): print(num_list[i]) # 결과는?? 결과는 1~ 10까지 숫자를 프린트 하고 범위가 넘어갔다는 OUT OF RANGE 같은 에러가 발생할 것 이다. 하지만 나는 이 에러가 발생해도 코드가 진행 되기를 원한다는 가정하에 아래 코드를 한번더 살펴 보도록 하겠다. # 리스트 생성 num_list = [1,2,3,4,5,6,7,8,9,1..

중간중간 코드를 실행하면서 부분적인 코드의 실행 시간을 확인이 필요할 때가 있는데. 그럴때 사용하는 코드이다. 매우 간단해서 긴글 보다는 코드로 설명하도록 하겠다.. import time start_time = time.time() sum = 0 for i in range(5) sum = sum + i end_time = time.time() print(f"실행시간 : {end_time - start_time}" 이렇게 0~ 4까지 더하는 반복문을 하나 실행하는데 걸리는 시간을 time 라이브러리를 이용하여 time.time()을 부르게 되면 이 매서드를 실행할 때 시간이 기록된다. 이를 이용해서 시작 그리고 종료의 값을 각각 저장하고 이를 빼주어 실행시간을 확인 할 수 있다.

kafka에 message를 보내기 위해서 파이썬으로 프로듀서를 구성해보았다. 우선먼저 필요사항 Python kafka-python 그리하여 먼저 Kafak-python 라이브러리를 설치한다. !pip install kafka-python 아주 가뿐하게 설치를 하고 나면 이제야 비로서 코드를 한번 알아보도록 하자. from kafka import KafkaProducer producer = KafkaProducer(bootstrap_servers='localhost:9092') for _ in range(100): producer.send('foobar', b'some_message_bytes') 세상 너무 간단하다.. 정말 이것으로 우리가 원하는 메세지를 생성할 수 있나? 실제로 가능하지만.. 너무 기..