''' pip install pandas,beautifulsoup4,finance-datareader -y ''' import FinanceDataReader as fdr from datetime import datetime, timedelta if __name__ == '__main__': now_datetime = datetime.now() before_one_week = (now_datetime - timedelta(weeks = 1)).strftime('%Y-%m-%d') df_ks11 = fdr.DataReader(symbol = 'KS11', start = before_one_week) print(df_ks11)
''' pip install pandas,beautifulsoup4,finance-datareader -y ''' import FinanceDataReader as fdr def get_kosdaq_dataframe(): df = fdr.StockListing('KRX') df = df[df['Market'] == 'KOSDAQ'] return df if __name__ == '__main__': df_kosdaq = get_kosdaq_dataframe() print(df_kosdaq.head(20))
''' pip install pandas,beautifulsoup4,finance-datareader -y ''' import FinanceDataReader as fdr def get_kospi_dataframe(): df = fdr.StockListing('KRX') df = df[df['Market'] == 'KOSPI'] return df if __name__ == '__main__': df_kospi = get_kospi_dataframe() print(df_kospi.head(20))
''' pip install pandas,beautifulsoup4,finance-datareader -y ''' import FinanceDataReader as fdr def search_code(name): df = fdr.StockListing('KRX') code = df[df['Name'] == name]['Code'].to_string(index = False) return code if __name__ == '__main__': code = search_code('LG에너지솔루션') df = fdr.DataReader(symbol = code, start = '2023-01-10', end = '2023-01-20') print(df)
''' pip install pandas,beautifulsoup4,finance-datareader -y ''' import FinanceDataReader as fdr def search_code(name): df = fdr.StockListing('KRX') code = df[df['Name'] == name]['Code'].to_string(index = False) return code if __name__ == '__main__': code_samsung = search_code('삼성전자') print(code_samsung, type(code_samsung)) code_sk = search_code('SK하이닉스') print(code_sk, type(code_sk))
아나콘다 가상환경 리스트 확인 conda env list python 가상환경 만들기 conda create -n py38 python==3.8 -y 가상환경 리스트 확인 conda env list 가상환경 접속 후 리스트 확인 conda activate py38 conda env list pyspark 3.3.1 설치 conda install -c conda-forge pyspark==3.3.1 -y 라이브러리 리스트 확인 pip list 간단한 pyspark 코드 실행해보기 from pyspark.sql import SparkSession from pyspark.sql.types import StructType, StructField, StringType, IntegerType spark = Spar..
다음과 같은 에러가 발생 Traceback (most recent call last): File "df_schema_null.py", line 23, in df = spark.createDataFrame(data = data, schema = schema) File "/Users/pgt0409/opt/anaconda3/envs/py38/lib/python3.8/site-packages/pyspark/sql/session.py", line 894, in createDataFrame return self._create_dataframe( File "/Users/pgt0409/opt/anaconda3/envs/py38/lib/python3.8/site-packages/pyspark/sql/session.py"..
from pyspark.sql import SparkSession from pyspark.sql.types import StructType, StructField, StringType, IntegerType spark = SparkSession \ .builder \ .master('local') \ .appName('my_pyspark_app') \ .getOrCreate() data = [ ('kim', 100), ('kim', 90), ('lee', 80), ('lee', 70), ('park', 60) ] schema = ['name', 'score'] df = spark.createDataFrame(data = data, schema = schema) df.printSchema() df.show..
from pyspark.sql import SparkSession from pyspark.sql.types import StructType, StructField, StringType, IntegerType spark = SparkSession \ .builder \ .master('local') \ .appName('my_pyspark_app') \ .getOrCreate() data = [ ('kim', 100), ('kim', 90), ('lee', 80), ('lee', 70), ('park', 60) ] schema = StructType([ \ StructField('name', StringType(), True), \ StructField('score', IntegerType(), True)..
+-------------------------------------------------------------+---------+-------------+ | Code | 100,000 | 100,000,000 | +-------------------------------------------------------------+---------+-------------+ | df.select("col_name").rdd.flatMap(lambda x: x).collect() | 0.4 | 55.3 | | list(df.select('col_name').toPandas()['col_name']) | 0.4 | 17.5 | | df.select('col_name').rdd.map(lambda row : ro..
