編集履歴

回答編集履歴

追記

2018/03/23 06:21

投稿

スコア5846

answer CHANGED Viewed

@@ -22,7 +22,6 @@
 ---
 質問文のコードに合わせる形で修正
-APIのドキュメントによると更新間隔が1m=60秒なので、5秒間隔でアクセスしなくても良いと思います。
 ```Python
 import time

追記

2018/03/23 06:21

投稿

umyu

スコア5846

answer CHANGED Viewed

@@ -1,46 +1,9 @@
+**＜＜　回答が長くなったので、最新のソースコード以外は削除しました。　＞＞**
 [Can I set max_retries for requests.request?
 ](https://stackoverflow.com/questions/15431044/can-i-set-max-retries-for-requests-request)
 上記サイトを参考にRetry処理を実装してみてはー。
-以下はサンプルソースコードです。
-```Python
-import json
-from datetime import datetime
-import requests
-from urllib3.util.retry import Retry
-from requests.adapters import HTTPAdapter
-def get_content(url: str='https://api.cryptowat.ch/markets/bitflyer/btcfxjpy/ohlc'):
-    s = requests.Session()
-    retries = Retry(total=5,
-                    backoff_factor=0.1,
-                    status_forcelist=[500, 502, 503, 504])
-    s.mount('https://', HTTPAdapter(max_retries=retries))
-    payload = {'periods': '60'}
-    r = s.get(url, params=payload)
-    return r.json()['result']['60']
-def data_write(obj):
-    file_name = f'{datetime.now().strftime("%Y%m%d_%H%M%S_%f")}.json'
-    print(f'file write:{file_name}')
-    with open(file_name, 'w', encoding='utf-8-sig') as f:
-        json.dump(obj, f)
-def main() -> None:
-    content = get_content()
-    print(content)
-    # file作成
-    data_write(content)
-if __name__ == '__main__':
-    main()
-```
 公開APIには負荷を掛けないように一度取得したものは、2度取得しないような形にしてくださいな。
 例えばファイルに書き出して、読み込む形にするなどの対応をしてくださいな。
 そうしないとAPIに負荷がかかりすぎて、APIからのアクセス拒否が行われたりやAPIが閉鎖され2度と使えなくなる事もあります。
@@ -58,11 +21,13 @@
 [cryptowat APIの使い方（備忘録）](https://qiita.com/KyoHeyyy/items/73e3201aa091a04ff248)
 ---
+質問文のコードに合わせる形で修正
-2018/03/23追記 ステータスコードを見るサンプルコード。
+APIのドキュメントによると更新間隔が1m=60秒なので、5秒間隔でアクセスしなくても良いと思います。
 ```Python
+import time
+from datetime import datetime
 import json
-from datetime import datetime
 import requests
 from urllib3.util.retry import Retry
 from requests.adapters import HTTPAdapter
@@ -79,7 +44,7 @@
     # ↓テスト用コード
     # r.status_code = 429
     if r.status_code == 429:
-        # APIのドキュメントにはレートリミット時にr.json()できるかどうかの保証の記述はなかったので注意です。
+        # APIのドキュメントにはr.json()できるかどうかの保証の記述はなかったので注意です。
         # r.json()出来ない場合は値:Noneを返してくださいな。
         return r.json(), r.status_code
     return r.json(), r.status_code
@@ -87,23 +52,30 @@
 def data_write(obj):
     file_name = f'{datetime.now().strftime("%Y%m%d_%H%M%S_%f")}.json'
-    print(f'file write:{file_name}')
+    #print(f'file write:{file_name}')
     with open(file_name, 'w', encoding='utf-8-sig') as f:
         json.dump(obj, f)
 def main() -> None:
+    CLOSE = 4
+    while True:
-    content, status_code = get_content()
+        content, status_code = get_content()
-    # rate_limitなら
+        # rate_limitなら
-    if status_code == 429:
+        if status_code == 429:
-        print('rate_limitです。')
+            # sleepタイムを55秒に
-        return
-    OHLC_60 = content['result']['60']
-    print(OHLC_60)
+            time.sleep(55)
-    # file作成
+            continue
-    data_write(OHLC_60)
+        json = content['result']['60']
+        close = json[-1][CLOSE]
+        print(str(datetime.fromtimestamp(round(time.time()) + 60 * 60 * 9)) + ' CLOSE: ' + str(close))  # 直近の終値の表示
+        # ファイルに保存したい時。
+        #data_write(json)
+        time.sleep(5)
 if __name__ == '__main__':
     main()

ステータスコードチェックを追加

2018/03/23 06:20

投稿

umyu

スコア5846

answer CHANGED Viewed

@@ -52,7 +52,59 @@
 2018/03/23追記
 [cryptowatch.jp API](https://cryptowatch.jp/docs/api)のドキュメントを見ると、レートリミットになるとステータスコード:429を返すみたいですね。
-ステータスコード判定してませんようね・・多分。。
+APIから帰ってくるステータスコード判定してませんようね・・多分。。
 ■参考情報
-[cryptowat APIの使い方（備忘録）](https://qiita.com/KyoHeyyy/items/73e3201aa091a04ff248)
+[cryptowat APIの使い方（備忘録）](https://qiita.com/KyoHeyyy/items/73e3201aa091a04ff248)
+---
+2018/03/23追記 ステータスコードを見るサンプルコード。
+```Python
+import json
+from datetime import datetime
+import requests
+from urllib3.util.retry import Retry
+from requests.adapters import HTTPAdapter
+def get_content(url: str='https://api.cryptowat.ch/markets/bitflyer/btcfxjpy/ohlc'):
+    s = requests.Session()
+    retries = Retry(total=5,
+                    backoff_factor=0.1,
+                    status_forcelist=[500, 502, 503, 504])
+    s.mount('https://', HTTPAdapter(max_retries=retries))
+    payload = {'periods': '60'}
+    r = s.get(url, params=payload)
+    # ↓テスト用コード
+    # r.status_code = 429
+    if r.status_code == 429:
+        # APIのドキュメントにはレートリミット時にr.json()できるかどうかの保証の記述はなかったので注意です。
+        # r.json()出来ない場合は値:Noneを返してくださいな。
+        return r.json(), r.status_code
+    return r.json(), r.status_code
+def data_write(obj):
+    file_name = f'{datetime.now().strftime("%Y%m%d_%H%M%S_%f")}.json'
+    print(f'file write:{file_name}')
+    with open(file_name, 'w', encoding='utf-8-sig') as f:
+        json.dump(obj, f)
+def main() -> None:
+    content, status_code = get_content()
+    # rate_limitなら
+    if status_code == 429:
+        print('rate_limitです。')
+        return
+    OHLC_60 = content['result']['60']
+    print(OHLC_60)
+    # file作成
+    data_write(OHLC_60)
+if __name__ == '__main__':
+    main()
+```

参考情報を追加

2018/03/23 03:35

投稿

umyu

スコア5846

answer CHANGED Viewed

@@ -46,4 +46,13 @@
 そうしないとAPIに負荷がかかりすぎて、APIからのアクセス拒否が行われたりやAPIが閉鎖され2度と使えなくなる事もあります。
 ■参考情報
-[python requestsでリトライ処理をする](https://qiita.com/toshitanian/items/c28a65fe2f32884e067c)
+[python requestsでリトライ処理をする](https://qiita.com/toshitanian/items/c28a65fe2f32884e067c)
+---
+2018/03/23追記
+[cryptowatch.jp API](https://cryptowatch.jp/docs/api)のドキュメントを見ると、レートリミットになるとステータスコード:429を返すみたいですね。
+ステータスコード判定してませんようね・・多分。。
+■参考情報
+[cryptowat APIの使い方（備忘録）](https://qiita.com/KyoHeyyy/items/73e3201aa091a04ff248)

参考情報を追加

2018/03/23 03:15

投稿

umyu

スコア5846

answer CHANGED Viewed

@@ -43,4 +43,7 @@
 公開APIには負荷を掛けないように一度取得したものは、2度取得しないような形にしてくださいな。
 例えばファイルに書き出して、読み込む形にするなどの対応をしてくださいな。
-そうしないとAPIに負荷がかかりすぎて、APIからのアクセス拒否が行われたりやAPIが閉鎖され2度と使えなくなる事もあります。
+そうしないとAPIに負荷がかかりすぎて、APIからのアクセス拒否が行われたりやAPIが閉鎖され2度と使えなくなる事もあります。
+■参考情報
+[python requestsでリトライ処理をする](https://qiita.com/toshitanian/items/c28a65fe2f32884e067c)

追記

2018/03/22 14:29

投稿

umyu

スコア5846

answer CHANGED Viewed

@@ -1,2 +1,46 @@
 [Can I set max_retries for requests.request?
-](https://stackoverflow.com/questions/15431044/can-i-set-max-retries-for-requests-request)
+](https://stackoverflow.com/questions/15431044/can-i-set-max-retries-for-requests-request)
+上記サイトを参考にRetry処理を実装してみてはー。
+以下はサンプルソースコードです。
+```Python
+import json
+from datetime import datetime
+import requests
+from urllib3.util.retry import Retry
+from requests.adapters import HTTPAdapter
+def get_content(url: str='https://api.cryptowat.ch/markets/bitflyer/btcfxjpy/ohlc'):
+    s = requests.Session()
+    retries = Retry(total=5,
+                    backoff_factor=0.1,
+                    status_forcelist=[500, 502, 503, 504])
+    s.mount('https://', HTTPAdapter(max_retries=retries))
+    payload = {'periods': '60'}
+    r = s.get(url, params=payload)
+    return r.json()['result']['60']
+def data_write(obj):
+    file_name = f'{datetime.now().strftime("%Y%m%d_%H%M%S_%f")}.json'
+    print(f'file write:{file_name}')
+    with open(file_name, 'w', encoding='utf-8-sig') as f:
+        json.dump(obj, f)
+def main() -> None:
+    content = get_content()
+    print(content)
+    # file作成
+    data_write(content)
+if __name__ == '__main__':
+    main()
+```
+公開APIには負荷を掛けないように一度取得したものは、2度取得しないような形にしてくださいな。
+例えばファイルに書き出して、読み込む形にするなどの対応をしてくださいな。
+そうしないとAPIに負荷がかかりすぎて、APIからのアクセス拒否が行われたりやAPIが閉鎖され2度と使えなくなる事もあります。