暗号通貨レート相関検索の例を使用したAnacondaとの連携



この記事の目的は、Anacondaを使用したデータ分析を簡単に紹介することです。 簡単なPythonスクリプトを作成して、さまざまな暗号通貨のデータを抽出、分析、視覚化します。

ステップ1-作業環境のセットアップ。


必要なスキルは、Pythonの基本的な理解だけです。

ステップ1.1-Anacondaのインストール

Anacondaディストリビューションは、 公式Webサイトからダウンロードできます。
インストールは、標準のステップバイステップモードで行われます。

ステップ1.2-プロジェクト作業環境のセットアップ

Anacondaのインストール後、依存関係を整理するために新しい環境を作成してアクティブ化する必要があります。

環境を使用する理由 コンピューターで複数のPythonプロジェクトを開発する予定がある場合は、競合を回避するために、依存関係(ソフトウェアライブラリとパッケージ)を個別に保存すると便利です。 Anacondaは、各プロジェクトの依存関係用の特別な環境ディレクトリを作成して、すべてを整理して分離します。

これは、コマンドラインから行うことができます

conda create --name cryptocurrency-analysis python=3.6 

 source activate cryptocurrency-analysis 

(Linux / macOS)

または

 activate cryptocurrency-analysis 

(Windows)

Anaconda Navigatorから



この場合、環境は自動的にアクティブ化されます。

次に、必要な依存関係NumPyPandasnb_condaJupiterPlotlyQuandlをインストールする必要があります。

 conda install numpy pandas nb_conda jupyter plotly quandl 

Anaconda Navigatorを介して、各パッケージを順番に



これには数分かかる場合があります。

ステップ1.3-Jupyterノートブックを起動する

また、 jupyter notebookコマンドラインからオプションを選択し、 http://localhost:8888/ブラウザーを開きhttp://localhost:8888/

そして、Anaconda Navigatorを介して



ステップ1.4-依存関係のインポート

空のJupyter Notebookを開いたら、最初に必要な依存関係をインポートします。

 import os import numpy as np import pandas as pd import pickle import quandl from datetime import datetime 

次に、オフラインPlotlyをインポートしてアクティブ化します。

 import plotly.offline as py import plotly.graph_objs as go import plotly.figure_factory as ff py.init_notebook_mode(connected=True) 

ステップ2-ビットコイン価格データの取得


すべてが設定されたので、分析用のデータの抽出を開始する準備ができました。 まず、無料のQuandl APIを使用して価格データを取得します。

ステップ2.1-Quandl関数の定義
Quandlからデータセットをロードおよびキャッシュするための関数を定義することから始めましょう。

 def get_quandl_data(quandl_id): '''Download and cache Quandl dataseries''' cache_path = '{}.pkl'.format(quandl_id).replace('/','-') try: f = open(cache_path, 'rb') df = pickle.load(f) print('Loaded {} from cache'.format(quandl_id)) except (OSError, IOError) as e: print('Downloading {} from Quandl'.format(quandl_id)) df = quandl.get(quandl_id, returns="pandas") df.to_pickle(cache_path) print('Cached {} at {}'.format(quandl_id, cache_path)) return df 

pickleを使用して、ダウンロードしたデータをシリアル化してファイルとして保存します。これにより、スクリプトを実行するたびにスクリプトが同じデータをリロードしないようにできます。

関数は、データをパンダデータセットとして返します。

ステップ2.2- クラーケン取引所でのビットコイン為替レートの取得

次のように実装します。

 btc_usd_price_kraken = get_quandl_data('BCHARTS/KRAKENUSD') 

スクリプトの実行の正確性を確認するために、head()メソッドを使用して受信した回答の最初の5行を見ることができます。

 btc_usd_price_kraken.head() 

結果:
日付開く高い低い閉じるボリューム(BTC)ボリューム(通貨)加重価格
2014-01-07874.67040892.06753810.00000810.0000015.62237813151.472844841.835522
2014-01-08810.00000899.84281788.00000824.9828719.18275616097.329584839.156269
2014-01-09825.56345870.00000807.42084841.869348.1583356784.249982831.572913
2014-01-10839.99000857.34056817.00000857.330568.0245106780.220188844.938794
2014-01-11858.20000918.05471857.16554899.8410518.74828516698.566929890.671709

そして、結果の配列を視覚化するグラフを作成します

 btc_trace = go.Scatter(x=btc_usd_price_kraken.index, y=btc_usd_price_kraken['Weighted Price']) py.iplot([btc_trace]) 



ここでは、Plotlyを使用して視覚化を生成します。 これはMatplotlibなどのよく知られているライブラリのいくつかよりも伝統的な選択ではありませんが、 D3.jsを使用して完全にインタラクティブな図を作成するPlotlyは素晴らしい選択だと思います

ステップ2.3-複数の取引所でビットコインレートを取得する

交換の性質は、価格設定が需要と供給によって決定されることであるため、交換にはビットコインの「真の価格」は含まれません。 この問題を解決するために、3つの大規模な取引所からデータをさらに抽出して、総合価格指数を計算します。

各エクスチェンジのデータを辞書にロードします。

 exchanges = ['COINBASE','BITSTAMP','ITBIT'] exchange_data = {} exchange_data['KRAKEN'] = btc_usd_price_kraken for exchange in exchanges: exchange_code = 'BCHARTS/{}USD'.format(exchange) btc_exchange_df = get_quandl_data(exchange_code) exchange_data[exchange] = btc_exchange_df 

ステップ2.4-すべての価格を単一のデータセットにまとめる

データを結合するための簡単な関数を定義します。

 def merge_dfs_on_column(dataframes, labels, col): series_dict = {} for index in range(len(dataframes)): series_dict[labels[index]] = dataframes[index][col] return pd.DataFrame(series_dict) 

次に、「加重価格」列のすべてのデータを結合します。

 btc_usd_datasets = merge_dfs_on_column(list(exchange_data.values()), list(exchange_data.keys()), 'Weighted Price') 

それでは、tail()メソッドを使用して最後の5行を見て、すべてが正常に表示され、希望どおりに表示されていることを確認しましょう。

 btc_usd_datasets.tail() 

結果:
日付ビットスタンプコインベースITBITクラーケンavg_btc_price_usd
2018-02-2810624.38289310643.05357310621.09942610615.58798710626.030970
2018-03-0110727.27260010710.94606410678.15687210671.65395310697.007372
2018-03-0210980.29865810982.18188110973.43404510977.06790910978.245623
2018-03-0311332.93446811317.10826211294.62076311357.53909511325.550647
2018-03-0411260.75125311250.77121111285.69072511244.83646811260.512414

ステップ2.5-価格データセットを比較します。

次の論理ステップは、受け取った価格の比較を視覚化することです。 これを行うには、Plotlyを使用して各交換のチャートを作成する補助関数を定義します。

 def df_scatter(df, title, seperate_y_axis=False, y_axis_label='', scale='linear', initial_hide=False): label_arr = list(df) series_arr = list(map(lambda col: df[col], label_arr)) layout = go.Layout( title=title, legend=dict(orientation="h"), xaxis=dict(type='date'), yaxis=dict( title=y_axis_label, showticklabels= not seperate_y_axis, type=scale ) ) y_axis_config = dict( overlaying='y', showticklabels=False, type=scale ) visibility = 'visible' if initial_hide: visibility = 'legendonly' trace_arr = [] for index, series in enumerate(series_arr): trace = go.Scatter( x=series.index, y=series, name=label_arr[index], visible=visibility ) if seperate_y_axis: trace['yaxis'] = 'y{}'.format(index + 1) layout['yaxis{}'.format(index + 1)] = y_axis_config trace_arr.append(trace) fig = go.Figure(data=trace_arr, layout=layout) py.iplot(fig) 

彼女に電話して

 df_scatter(btc_usd_datasets, '    (USD) ') 

結果:



ここで、すべてのゼロ値を削​​除します。これは、検討している期間中に価格がゼロになったことがないことがわかっているためです。

 btc_usd_datasets.replace(0, np.nan, inplace=True) 

そして、スケジュールを再作成します

 df_scatter(btc_usd_datasets, 'Bitcoin Price (USD) By Exchange') 

結果:



ステップ2.6-平均価格の計算

これで、すべての取引所でのビットコインの1日の平均価格を含む新しい列を計算できます。

 btc_usd_datasets['avg_btc_price_usd'] = btc_usd_datasets.mean(axis=1) 

この新しい列は、ビットコインの価格指数です。 正常に見えるようにプロットします。

 btc_trace = go.Scatter(x=btc_usd_datasets.index, y=btc_usd_datasets['avg_btc_price_usd']) py.iplot([btc_trace]) 

結果:



後でこのデータを使用して、他の暗号通貨の為替レートを米ドルに変換します。

ステップ3-代替暗号通貨のデータを取得する



ビットコイン価格のデータの配列ができたので、代替の暗号通貨に関するデータをいくつか見てみましょう。

ステップ3.1-Poloniex APIを操作するための関数を定義します。

Poloniex APIを使用てデータを取得します。 このAPIからJSONデータをロードおよびキャッシュするための2つのヘルパー関数を定義します。

最初に、提供されたURLからJSONデータをロードしてキャッシュするget_json_data関数を定義します。

 def get_json_data(json_url, cache_path): try: f = open(cache_path, 'rb') df = pickle.load(f) print('Loaded {} from cache'.format(json_url)) except (OSError, IOError) as e: print('Downloading {}'.format(json_url)) df = pd.read_json(json_url) df.to_pickle(cache_path) print('Cached response at {}'.format(json_url, cache_path)) return df 

次に、Poloniex API HTTPリクエストをフォーマットする関数を定義し、新しいget_json_data関数を呼び出して、受信したデータを保存します。

 base_polo_url = 'https://poloniex.com/public?command=returnChartData&currencyPair={}&start={}&end={}&period={}' start_date = datetime.strptime('2015-01-01', '%Y-%m-%d') end_date = datetime.now() pediod = 86400 def get_crypto_data(poloniex_pair): json_url = base_polo_url.format(poloniex_pair, start_date.timestamp(), end_date.timestamp(), pediod) data_df = get_json_data(json_url, poloniex_pair) data_df = data_df.set_index('date') return data_df 

この入力関数は、「BTC_ETH」などの暗号通貨のペアを受け取り、2つの通貨の為替レートの履歴データを返します。

ステップ3.2-Poloniexからのデータのダウンロード

考えられる代替暗号通貨の一部は、米ドルで直接取引所で購入することはできません。 このため、各通貨の為替レートをビットコインにアップロードし、ビットコインの価格に関する既存のデータを使用して、この値を米ドルに変換します。

イーサリアムライトコインリップルイーサリアム クラシックステラダッシュシアコインモネロNEMの 9つの一般的な暗号通貨の交換データをダウンロードします。

 altcoins = ['ETH','LTC','XRP','ETC','STR','DASH','SC','XMR','XEM'] altcoin_data = {} for altcoin in altcoins: coinpair = 'BTC_{}'.format(altcoin) crypto_price_df = get_crypto_data(coinpair) altcoin_data[altcoin] = crypto_price_df 

現在、9つのデータセットがあり、各データセットには、ビットコインと代替暗号通貨の過去の平均日次交換比率が含まれています。

イーサリアムの価格表の最後の数行を見て、正常に見えることを確認できます。

 altcoin_data['ETH'].tail() 

日付閉じる高い低い開くquoteVolumeボリューム加重平均
2018-03-010.0797350.0829110.0792320.08272917981.7336931454.2061330.080871
2018-03-020.0775720.0797190.0770140.07971918482.9855541448.7327060.078382
2018-03-030.0745000.0776230.0743560.07756215058.8256461139.6403750.075679
2018-03-040.0751110.0776300.0743890.07450012258.662182933.4809510.076149
2018-03-050.0753730.0757000.0747230.07527710993.285936826.5766930.075189

ステップ3.3-価格をUSDに変換します。

各暗号通貨のビットコイン交換レートと米ドルの履歴ビットコイン価格指数があるため、各代替暗号通貨の価格を米ドルで直接計算できます。

 for altcoin in altcoin_data.keys(): altcoin_data[altcoin]['price_usd'] = altcoin_data[altcoin]['weightedAverage'] * btc_usd_datasets['avg_btc_price_usd'] 

これにより、価格が米ドルの代替暗号通貨の各データセットに新しい列を作成しました。

その後、 merge_dfs_on_column関数を再利用して、暗号通貨ごとに価格データの組み合わせセットを米ドルで作成できます。

 combined_df = merge_dfs_on_column(list(altcoin_data.values()), list(altcoin_data.keys()), 'price_usd') 

最後のビット列としてビットコイン価格をデータセットに追加しましょう。

 combined_df['BTC'] = btc_usd_datasets['avg_btc_price_usd'] 

その結果、検討中の10の暗号通貨の1日の米ドル価格を含むデータセットがあります。

df_scatter関数を使用して、すべての暗号通貨価格をチャートに表示します。

 df_scatter(combined_df, '  (USD)', seperate_y_axis=False, y_axis_label='(USD)', scale='log') 

このグラフは、過去数年間で各通貨の為替レートがどのように変化したかを示す非常に堅実な「全体像」を示しています。



この例では、Y軸の対数目盛を使用して、同じセクション内のすべての通貨を比較します。 さまざまなパラメーター値(scale = 'linear'など)を試して、データのさまざまな視点を取得できます。

ステップ3.4-暗号通貨相関の計算。

暗号通貨の為替レートは、値やボラティリティがまったく異なるにもかかわらず、わずかに相関しているように見えるかもしれません。 そして、2017年4月の急増からわかるように、小さな変動でさえ市場全体で同期して発生しているようです。

Pandas corr ()メソッドを使用して相関仮説をテストできます。このメソッドは、データセット内の各列のピアソン相関係数を相互に計算します。 計算では、データセットの各セルを価格の絶対値からパーセンテージの変化に変換するpct_change ()メソッドも使用します。

最初に、2016年の相関を計算します。

 combined_df_2016 = combined_df[combined_df.index.year == 2016] combined_df_2016.pct_change().corr(method='pearson') 

結果:
ダッシュEctEtLTCSCSTRXemXMRXrpBTC
ダッシュ1.0000000.0039920.122695-0.0121940.0266020.0580830.0145710.1215370.088657-0.014040
Ect0.0039921.000000-0.181991-0.131079-0.008066-0.102654-0.080938-0.105898-0.054095-0.170538
Et0.122695-0.1819911.000000-0.0646520.1696420.0350930.0432050.0872160.085630-0.006502
LTC-0.012194-0.131079-0.0646521.0000000.0122530.1135230.1606670.1294750.0537120.750174
SC0.026602-0.0080660.1696420.0122531.0000000.1432520.1061530.0479100.0210980.035116
STR0.058083-0.1026540.0350930.1135230.1432521.0000000.2251320.0279980.3201160.079075
Xem0.014571-0.0809380.0432050.1606670.1061530.2251321.0000000.0164380.1013260.227674
XMR0.121537-0.1058980.0872160.1294750.0479100.0279980.0164381.0000000.0276490.127520
Xrp0.088657-0.0540950.0856300.0537120.0210980.3201160.1013260.0276491.0000000.044161
BTC-0.014040-0.170538-0.0065020.7501740.0351160.0790750.2276740.1275200.0441611.000000

1または-1に近い係数は、データがそれぞれ強く相関または逆相関していることを意味し、ゼロに近い係数は、値が互いに独立して変動する傾向があることを意味します。

これらの結果を視覚化するために、別のヘルパー関数を作成します。

 def correlation_heatmap(df, title, absolute_bounds=True): heatmap = go.Heatmap( z=df.corr(method='pearson').as_matrix(), x=df.columns, y=df.columns, colorbar=dict(title='Pearson Coefficient'), ) layout = go.Layout(title=title) if absolute_bounds: heatmap['zmax'] = 1.0 heatmap['zmin'] = -1.0 fig = go.Figure(data=[heatmap], layout=layout) py.iplot(fig) 

 correlation_heatmap(combined_df_2016.pct_change(), "  (2016)") 



ここで、濃い赤の値は強い相関を表し、青の値は強い逆相関を表します。 他のすべての色は、微妙な/存在しない相関の度合いを表します。

このチャートは何を教えてくれますか? 実際、これは、2016年中にさまざまな暗号通貨の価格がどのように変動したかについて、統計的に有意な関係がほとんどなかったことを示しています。

ここで、ここ数か月で暗号通貨の相関性が高まっているという仮説をテストするために、2017年と2018年のデータを使用して同じテストを繰り返しましょう。

 combined_df_2017 = combined_df[combined_df.index.year == 2017] combined_df_2017.pct_change().corr(method='pearson') 

結果:
ダッシュEctEtLTCSCSTRXemXMRXrpBTC
ダッシュ1.0000000.3875550.5069110.3401530.2914240.1830380.3259680.4984180.0911460.307095
Ect0.3875551.0000000.6014370.4820620.2984060.2103870.3218520.4473980.1147800.416562
Et0.5069110.6014371.0000000.4376090.3730780.2593990.3992000.5546320.2123500.410771
LTC0.3401530.4820620.4376091.0000000.3391440.3075890.3790880.4372040.3239050.420645
SC0.2914240.2984060.3730780.3391441.0000000.4029660.3313500.3786440.2438720.325318
STR0.1830380.2103870.2593990.3075890.4029661.0000000.3395020.3274880.5098280.230957
Xem0.3259680.3218520.3992000.3790880.3313500.3395021.0000000.3360760.2681680.329431
XMR0.4984180.4473980.5546320.4372040.3786440.3274880.3360761.0000000.2266360.409183
Xrp0.0911460.1147800.2123500.3239050.2438720.5098280.2681680.2266361.0000000.131469
BTC0.3070950.4165620.4107710.4206450.3253180.2309570.3294310.4091830.1314691.000000

 correlation_heatmap(combined_df_2017.pct_change(), "  (2017)") 



 combined_df_2018 = combined_df[combined_df.index.year == 2018] combined_df_2018.pct_change().corr(method='pearson') 

ダッシュEctEtLTCSCSTRXemXMRXrpBTC
ダッシュ1.0000000.7755610.8565490.8479470.7331680.7172400.7691350.9130440.7796510.901523
Ect0.7755611.0000000.8088200.6674340.5308400.5512070.6417470.6960600.6376740.694228
Et0.8565490.8088201.0000000.7007080.6248530.6303800.7523030.8168790.6521380.787141
LTC0.8479470.6674340.7007081.0000000.6837060.5966140.5936160.7659040.6441550.831780
SC0.7331680.5308400.6248530.6837061.0000000.6152650.6951360.6260910.7194620.723976
STR0.7172400.5512070.6303800.5966140.6152651.0000000.7904200.6428100.8540570.669746
Xem0.7691350.6417470.7523030.5936160.6951360.7904201.0000000.7443250.8297370.734044
XMR0.9130440.6960600.8168790.7659040.6260910.6428100.7443251.0000000.6680160.888284
Xrp0.7796510.6376740.6521380.6441550.7194620.8540570.8297370.6680161.0000000.712146
BTC0.9015230.6942280.7871410.8317800.7239760.6697460.7340440.8882840.7121461.000000

 correlation_heatmap(combined_df_2018.pct_change(), "  (2018)") 



そして今、私たちが仮定したことを見ることができます-ほとんどすべての暗号通貨は、すべての方向で互いに相互接続されています。

これについては、Anacondaでのデータ操作の概要が正常に完了したと仮定します。

Source: https://habr.com/ru/post/J350500/


All Articles