常連

pythonのコードで質問です。

from coinapi_v1 import CoinAPIv1
import datetime

test_key = 'xxxxxxxxxxxxxxxxxxxxxxxxx'

api = CoinAPIv1(test_key)
exchanges = api.metadata_list_exchanges()

symbols = api.metadata_list_symbols()
print('Symbols')
for symbol in symbols:
   #if(symbol['exchange_id']=="BITFINEX"): <= 例 BITFINEX を指定した場合
   if(symbol['exchange_id']=="wwwwwww"):
       print('Symbol ID: %s' % symbol['symbol_id'])


上記のコードを実行すると、
ModuleNotFoundError: No module named 'coinapi_v1'
というエラーが出てしまいます。

coinapiのモジュールがないのが原因だと思うのですが、
何を入れたらいいのかわかりません。

pip install coinapi_v1
をプロンプトで実行してもそんなモジュールはないみたいで引っ掛かりません。

仕様書（https://github.com/coinapi/coinapi-sdk）を読んでみても何を入れたらいいのかがイマイチわかりません。
理解が足りずすみませんが、お知恵を拝借できますと嬉しいです。
よろしくお願いいたします。

Pythonでのapiのエラーについて

### 前提

bitflyer Realtime APIに、websocketで接続して得たデータを変数に格納するために
試行錯誤しましたが、やり方がわかりませんでした

### 実現したいこと

bitflyer Realtime APIに、websocketで接続して得たデータを変数に格納する

### 発生している問題・エラーメッセージ

--- Logging error ---
Traceback (most recent call last):
  File "/Users/a1/opt/anaconda3/envs/m/lib/python3.9/site-packages/websocket/_app.py", line 383, in run_forever
    dispatcher.read(self.sock.sock, read, check)
  File "/Users/a1/opt/anaconda3/envs/m/lib/python3.9/site-packages/websocket/_app.py", line 64, in read
    r = self.select()
  File "/Users/a1/opt/anaconda3/envs/m/lib/python3.9/site-packages/websocket/_app.py", line 78, in select
    r = sel.select(self.ping_timeout)
  File "/Users/a1/opt/anaconda3/envs/m/lib/python3.9/selectors.py", line 562, in select
    kev_list = self._selector.control(None, max_ev, timeout)
KeyboardInterrupt

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/Users/a1/opt/anaconda3/envs/m/lib/python3.9/site-packages/websocket/_app.py", line 424, in _callback
    callback(self, *args)
TypeError: on_close() takes 2 positional arguments but 4 were given

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "/Users/a1/opt/anaconda3/envs/m/lib/python3.9/logging/__init__.py", line 1086, in emit
    stream.write(msg + self.terminator)
AttributeError: 'int' object has no attribute 'write'
Call stack:
  File "/Users/a1/Desktop/ml/main.py", line 14, in <module>
    json_rpc = RealtimeAPI(url=url, channel=channel)
  File "/Users/a1/Desktop/ml/bitflyer.py", line 15, in __init__
    self.connect()
  File "/Users/a1/Desktop/ml/bitflyer.py", line 22, in connect
    self.ws.run_forever()
  File "/Users/a1/opt/anaconda3/envs/m/lib/python3.9/site-packages/websocket/_app.py", line 390, in run_forever
    teardown()
  File "/Users/a1/opt/anaconda3/envs/m/lib/python3.9/site-packages/websocket/_app.py", line 318, in teardown
    self._callback(self.on_close, close_status_code, close_reason)
  File "/Users/a1/opt/anaconda3/envs/m/lib/python3.9/site-packages/websocket/_app.py", line 429, in _callback
    self.on_error(self, e)
  File "/Users/a1/Desktop/ml/bitflyer.py", line 35, in on_error
    logger.error(error)
Message: TypeError('on_close() takes 2 positional arguments but 4 were given')
Arguments: ()

### 該当のソースコード

使用言語　python3.9

コード　ファイル名　bitflyer.py
```
import logging
import websocket
import json

import pybitflyer

logger = logging.getLogger(__name__)#logging
ticker_data = 0#追記

class RealtimeAPI(object):

    def __init__(self, url, channel):
        self.url = url
        self.channel = channel
        self.connect()

    def connect(self):
        self.ws = websocket.WebSocketApp\
            (self.url,header=None,on_open=self.on_open,\
                 on_message=self.on_message, on_error=self.on_error,\
                     on_close=self.on_close)
        self.ws.run_forever()
        logger.info('Web Socket process ended.')

    """
    Below are callback functions of websocket.
    """
    # when we get message
    def on_message(self, ws, message):
        resp = json.loads(message)['params']['message']
        self.set_realtime_ticker(resp)

    # when error occurs
    def on_error(self, ws, error):
        logger.error(error)

    # when websocket closed.
    def on_close(self, ws):
        logger.info('disconnected streaming server')

    # when websocket opened.
    def on_open(self, ws):
        logger.info('connected streaming server')
        input_data = json.dumps(
            {'method' : 'subscribe',
            'params' : {'channel' : self.channel}
            }
        )
        ws.send(input_data)

    def set_realtime_ticker(self, resp):
        timestamp = resp['timestamp']
        product_code = resp['product_code']
        volume = float(resp['volume'])
        ticker = [product_code, timestamp, volume]
        print(ticker)
        logger.info(f'ticker={ticker}')

        global ticker_data#追記
        ticker_data = ticker#追記

print(ticker_data)#ここにAPIから入ってくるtickerのデータを入れたいです

---------------------------------ここからもう一つのファイル---------------------------------------
#ファイル名　main.py
import logging
import sys

from bitflyer import RealtimeAPI

logging.basicConfig(level=logging.INFO, stream=sys.stdout)
# logging.basicConfig(level=logging.INFO, stream=a)
#ログレベル INFO　出力先　stream=sys.stdout

if __name__ == "__main__":
    url = "wss://ws.lightstream.bitflyer.com/json-rpc"
    channel = "lightning_ticker_FX_BTC_JPY"
    json_rpc = RealtimeAPI(url=url, channel=channel)


------------------------------コードはここまで---------------------------------------

### 試したこと

①ファイル名bitflyer.pyのdef set_realtime_tickerにあるtickerをグローバル変数にした
②ファイル名　main.pyのlogging.basicConfigにあるstream=変数にした

### 補足情報（FW/ツールのバージョンなど）
Visual Studio Codeを使用しています

ここにより詳細な情報を記載してください。

よろしくお願いいたします

bitflyer Realtime APIに、websocketで接続して得たデータを変数に格納する

###前提・実現したいこと
初歩的な事で恐縮ですが、CCXTでBitflyerに出した注文を管理したいです。
###発生している問題・エラーメッセージ
```
C:\Users\user\program>python program.py
[]
```
予め指値で注文を入れ、未約定の状態で実行しました。
表示されるのは　[]　のみでエラーなのかすら判別できません。

###該当のソースコード
```
import ccxt
from pprint import pprint

bitflyer = ccxt.bitflyer()
bitflyer.apiKey = "XXXXXXXXXXXXXXXXXXX" #APIKEY
bitflyer.secret = "XXXXXXXXXXXXXXXXXXX" #APISECRET

orders = bitflyer.fetch_open_orders(
	symbol = "BTC/JPY",
	params = { "product_code" : "FX_BTC_JPY" })
pprint( orders )
```

###自分で調べたことや試したこと
fetch_ordersでも同様 [] が返ってくるのみでした。

###使っているツールのバージョンなど補足情報
python3.8
windows10 62bit
エディタはAtomを使用しています。

python3 bitcoin ccxt bitflyer （約定・未約定）注文情報の取得

取引所から、過去のローソク足データを取得するにあたり、下記のコードを実行しました。
しかし、
2017/09/07以前のデータについて、2017/08/17-2017/09-07が永遠とループされます。
（＜画像1＞参照。X軸15000以前が不自然にループされる。）
原因は何だと考えられるでしょうか。

また、デフォルトの取引所（binance）以外の別の取引所、例えばbitbankやbitflyerからBTC/JPYペアのデータを取得するため、
下記コードを
exchange = ccxt.bitflyer()
symbol = "BTC/JPY"
として実行してみたところ、今度は、＜画像２＞のような結果となりました。

よろしければ、考えられる原因を教えていただけないでしょうか。


```
import ccxt
import pandas as pd
import matplotlib.pyplot as plt
import datetime
from time import sleep
# 一度にとれるろうそく足は500本までなので、分けて取得する
def get_past_data_from_server(exchange,data_n,data_m,bar,barsymbol,symbol):
   pastdata = pd.DataFrame([])
   # 一度のAPIコールでとれるろうそく足は500本までなので、分けて取得する
   # 過去データの取得
   for i in range(0, data_m):
       sleep(0.001)
       data = get_past_data(exchange,data_n * (data_m - i),bar,barsymbol,symbol)
       data.index = list(range(len(pastdata), len(pastdata) + len(data)))
       pastdata = pd.concat([pastdata, data])
   return pastdata
def get_past_data(exchange,period,bar,barsymbol,symbol):
   while(True):
       try:
           timest = exchange.fetch_ticker(symbol)['timestamp']
           period += 1
           timest = timest - period*bar*60*1000
           candles = exchange.fetch_ohlcv(symbol, timeframe=barsymbol, since=timest)
           pd_candles = pd.DataFrame(candles)
           break
       except Exception as e:
           print(e)
           print("データの取得に失敗しました")
           sleep(5)
           continue
   return pd_candles

# 取引所binanceを指定
exchange = ccxt.binance ()
# 通貨ペアの設定
symbol = "BTC/USDT"
# 何分足?
bar = 60
barsymbol = '1h'
# data_n*data_m本のろうそく足を取得
# data_nはbinanceでは500に固定
data_n = 500
data_m=80
data = get_past_data_from_server(exchange,data_n,data_m,bar,barsymbol,symbol)

# unixtime(ミリ秒)を日時に変換
for i in range(0,len(data)):
    data[0][i]= datetime.datetime.fromtimestamp(data[0][i]/1000)

plt.plot(data[4])
plt.show()

data.to_csv("binance_btc_usdt_1h.csv", header=False, index=False)


#https://note.com/mocchi999/n/n44da0e74a68a で紹介されているコードを使用させて頂きました
```
＜画像１＞
![イメージ説明](96c693d52dd8c7736b118c3869147c44.png)

＜画像２＞
![イメージ説明](52dda33ed95176ffb0801510f3f43dc3.png)

取引所のチャートデータをAPIで取得

閲覧ありがとうございます。

Pythonで、ccxtから板情報を1秒ごとに取得し、1時間ごとcsvに出力するとというプログラムを書いています。

コードは以下になるのですが、型変換の部分が違うのかデータが取り出せません。

初心者なのでおかしな部分が多々あるかもしれませんが、お分かりになる方がいらっしゃればご助言いただきたいです。
よろしくお願いいたします。

```python
import ccxt
import time
from datetime import datetime as dt
import pandas as pd
import json
import os
import requests
import json

#ccxtから取引所を読み込む
exchange = ccxt.bitflyer()
exchange.load_markets()
#通貨ペア
symbol = 'BTC/JPY'
order_book = exchange.fetch_order_book(symbol)
#スリープ秒数
sleep_t = 1
#板の深さ
depth = 5

#板データ取得
def get_board():
    data = order_book
    #jsonデータを辞書型へ変換
    board = json.loads(data.text)
    #現在時刻の取得
    dict_data = {'time' : dt.now()}
    dict_data.update({'ask_price_{}'.format(i) : board['asks'][i]['price'] for i in range(depth)})
    dict_data.update({'ask_price_{}'.format(i) : board['asks'][i]['size'] for i in range(depth)})
    dict_data.update({'bid_price_{}'.format(i) : board['bids'][i]['price'] for i in range(depth)})
    dict_data.update({'bid_price_{}'.format(i) : board['bids'][i]['size'] for i in range(depth)})
    #辞書型をpandas seriesに変換
    return pd.Series(dict_data)

#ループ処理
def get_coin_board():
    init_time = dt.now()
    end_time = dt.now()
    print('START /', init_time)
    main_list = []
    while (end_time - init_time).seconds < 3600:
        try:
            #jsonデータをpandas seriesへ変換
            dict_data = get_board()
            #pandas seriesをリストへ追加
            main_list.append(dict_data)
        except Exception as e:
            print('exception: ',e.args)
        time.sleep(sleep_t)
        end_time = dt.now()
    #pandas seriesのリストを結合
    df_data = pd.concat(main_list, axis=1).T
    df_data.to_csv('./data/exchange_hourly_board_day_{}_init_{}_{}_end_{}_{}.csv'.format(init_time.day, init_time.hour, init_time.minute, end_time.hour, end_time.minute))
    print('END /', end_time)
    
if __name__ == '__main__':
    if not os.path.exists('./data'):
        os.mkdir('./data')
    while True:
        try:
            get_coin_board()
        except Exception as e:
            print('exception: ', e.args)
```


出力されたエラー
exception:  ("'dict' object has no attribute 'text'",)

 File "*******", line 62, in <module>
    get_coin_board()

  File "******", line 50, in get_coin_board
    time.sleep(sleep_t)

[Python]ccxtで取得した板情報を整理してcsvに出せない

### 前提
ここ何年かBitcoin等の仮想通貨の取引が盛んになってきています。私は、「日給300万円のSS級トレーダーが明かす botterのリアル」という本を読んで、仮想通貨をBot(一定のタスクや処理を自動化するためのアプリケーション)により、仮想通貨を取引する取引所へAPIを通じて、過去の取引のデータを収集しSQLight等のDBに格納したり、売買注文をAPIを通じて発注するプログラム(Bot)を作ろうとしています。

ただし、私は日曜プログラマーで趣味でプログラムをかじっている程度なので設計のノウハウ等を持っておらず、0から作る能力がないので、既存のオープンソースでのフレームワークを探して、コードを分析して別言語に移植したりカスタマイズしたりしたいと考えておりました。

そこで、日本産でオープンソースで良いものが無かったので、海外産で評価の高い「Gekko」というnode.jsで書かれたフレームワークを使うことにしました。

■Gekkoの公式サイト
https://note.com/tonacoin/n/n2fbe86f96fa2
■日本語の紹介サイト
https://note.com/tonacoin/n/n2fbe86f96fa2

私の環境はWin10 Proなので、上記の日本語の紹介サイトを参考に(Githubのリンクが切れていたり等があったので適宜手順を修正し)下記を実施しました。

【Gekkoインストール・実行手順】
①node.js をインストール  https://nodejs.org/ja/
② GekkoをGitHub https://github.com/askmike/gekko からダウンロードし適当なフォルダに配置（私はDownloadフォルダ）
③ターミナルから下記のコマンドを実行
　$ cd C:\Users\***\Downloads\gekko-develop(***はユーザ名)
　$ npm install
④本来なら、ここで下記コマンドを実行すると、
   $ node gekko --ui
Webブラウザから「 http://localhost:3000/#/home 」にてサービスにアクセス可能となる筈ですが、
「ERROR: Cannot find the specified config file.」とエラーが出ます。
 
ソースコードを追いかけると、解凍した「gekko-develop」フォルダ内の「gekko.js」スクリプトの47行目の「const config = util.getConfig();」でコケているようです。なお、「util」は「gekko.js」スクリプトの35行目の「const util = require(__dirname + '/core/util');」でモジュールの読み込みを実行しています。

対象の「gekko-develop/core/util.js」を読むと、更にここの行20～行26行目でコケているように見えることが分かりました。
「program.config」というオブジェクトが見つからず、「'Please specify a config file.'」というメッセージを発しているようです。
なお、programは本「util.js」の6行目の「var program = require('commander');」で読み込んだモジュールで、
「commander」はコマンドライン引数をハッシュとして格納する機能を持っているようなので、コンフィグファイルをコマンドラインで指定して実行してみましたが全く巧くいかないため途方に暮れています。「util.js」の173行の指定に従って実行したのですが…。

program
  .version(util.logVersion())
  .option('-c, --config <file>', 'Config file')

実際に実行したコマンドは「試したこと」に載せます。

### 実現したいこと
コンフィグファイルを指定して、gekkoをUI付きで起動したい。

### 発生している問題・エラーメッセージ

```
   /      \ /        |/  |  /  |/  |  /  | /      \
  /$$$$$$  |$$$$$$$$/ $$ | /$$/ $$ | /$$/ /$$$$$$  |
  $$ | _$$/ $$ |__    $$ |/$$/  $$ |/$$/  $$ |  $$ |
  $$ |/    |$$    |   $$  $$<   $$  $$<   $$ |  $$ |
  $$ |$$$$ |$$$$$/    $$$$$  \  $$$$$  \  $$ |  $$ |
  $$ \__$$ |$$ |_____ $$ |$$  \ $$ |$$  \ $$ \__$$ |
  $$    $$/ $$       |$$ | $$  |$$ | $$  |$$    $$/
   $$$$$$/  $$$$$$$$/ $$/   $$/ $$/   $$/  $$$$$$/

        Gekko v0.6.8
        I'm gonna make you rich, Bud Fox.

 ERROR: Cannot find the specified config file.
```

### 該当のソースコード

```ここに言語名を入力
// GitHub https://github.com/askmike/gekko より抜粋

/**********************gekko.js****************************/

console.log(`
    ______   ________  __    __  __    __   ______
   /      \\ /        |/  |  /  |/  |  /  | /      \\
  /$$$$$$  |$$$$$$$$/ $$ | /$$/ $$ | /$$/ /$$$$$$  |
  $$ | _$$/ $$ |__    $$ |/$$/  $$ |/$$/  $$ |  $$ |
  $$ |/    |$$    |   $$  $$<   $$  $$<   $$ |  $$ |
  $$ |$$$$ |$$$$$/    $$$$$  \\  $$$$$  \\  $$ |  $$ |
  $$ \\__$$ |$$ |_____ $$ |$$  \\ $$ |$$  \\ $$ \\__$$ |
  $$    $$/ $$       |$$ | $$  |$$ | $$  |$$    $$/ 
   $$$$$$/  $$$$$$$$/ $$/   $$/ $$/   $$/  $$$$$$/
`);

const util = require(__dirname + '/core/util');

console.log('\tGekko v' + util.getVersion());
console.log('\tI\'m gonna make you rich, Bud Fox.', '\n\n');

const dirs = util.dirs();

if(util.launchUI()) {
  return require(util.dirs().web + 'server');
}

const pipeline = require(dirs.core + 'pipeline');
const config = util.getConfig();
const mode = util.gekkoMode();

if(
  config.trader &&
  config.trader.enabled &&
  !config['I understand that Gekko only automates MY OWN trading strategies']
)
  util.die('Do you understand what Gekko will do with your money? Read this first:\n\nhttps://github.com/askmike/gekko/issues/201');

// > Ever wonder why fund managers can't beat the S&P 500?
// > 'Cause they're sheep, and sheep get slaughtered.
pipeline({
  config: config,
  mode: mode
});



/**********************gekko.js****************************/

var moment = require('moment');
var _ = require('lodash');
var path = require('path');
var fs = require('fs');
var semver = require('semver');
var program = require('commander');

var startTime = moment();

var _config = false;
var _package = false;
var _nodeVersion = false;
var _gekkoMode = false;
var _gekkoEnv = false;

var _args = false;

// helper functions
var util = {
  getConfig: function() {
    // cache
    if(_config)
      return _config;

    if(!program.config)
        util.die('Please specify a config file.', true);

    if(!fs.existsSync(util.dirs().gekko + program.config))
      util.die('Cannot find the specified config file.', true);

    _config = require(util.dirs().gekko + program.config);
    return _config;
  },
  // overwrite the whole config
  setConfig: function(config) {
    _config = config;
  },
  setConfigProperty: function(parent, key, value) {
    if(parent)
      _config[parent][key] = value;
    else
      _config[key] = value;
  },
  getVersion: function() {
    return util.getPackage().version;
  },
  getPackage: function() {
    if(_package)
      return _package;


    _package = JSON.parse( fs.readFileSync(__dirname + '/../package.json', 'utf8') );
    return _package;
  },
  getRequiredNodeVersion: function() {
    return util.getPackage().engines.node;
  },
  recentNode: function() {
    var required = util.getRequiredNodeVersion();
    return semver.satisfies(process.version, required);
  },
  // check if two moments are corresponding
  // to the same time
  equals: function(a, b) {
    return !(a < b || a > b)
  },
  minToMs: function(min) {
    return min * 60 * 1000;
  },
  defer: function(fn) {
    return function(args) {
      var args = _.toArray(arguments);
      return _.defer(function() { fn.apply(this, args) });
    }
  },
  logVersion: function() {
    return  `Gekko version: v${util.getVersion()}`
    + `\nNodejs version: ${process.version}`;
  },
  die: function(m, soft) {

    if(_gekkoEnv === 'child-process') {
      return process.send({type: 'error', error: '\n ERROR: ' + m + '\n'});
    }

    var log = console.log.bind(console);

    if(m) {
      if(soft) {
        log('\n ERROR: ' + m + '\n\n');
      } else {
        log(`\nGekko encountered an error and can\'t continue`);
        log('\nError:\n');
        log(m, '\n\n');
        log('\nMeta debug info:\n');
        log(util.logVersion());
        log('');
      }
    }
    process.exit(1);
  },
  dirs: function() {
    var ROOT = __dirname + '/../';

    return {
      gekko: ROOT,
      core: ROOT + 'core/',
      markets: ROOT + 'core/markets/',
      exchanges: ROOT + 'exchange/wrappers/',
      plugins: ROOT + 'plugins/',
      methods: ROOT + 'strategies/',
      indicators: ROOT + 'strategies/indicators/',
      budfox: ROOT + 'core/budfox/',
      importers: ROOT + 'importers/exchanges/',
      tools: ROOT + 'core/tools/',
      workers: ROOT + 'core/workers/',
      web: ROOT + 'web/',
      config: ROOT + 'config/',
      broker: ROOT + 'exchange/'
    }
  },
  inherit: function(dest, source) {
    require('util').inherits(
      dest,
      source
    );
  },
  makeEventEmitter: function(dest) {
    util.inherit(dest, require('events').EventEmitter);
  },
  setGekkoMode: function(mode) {
    _gekkoMode = mode;
  },
  gekkoMode: function() {
    if(_gekkoMode)
      return _gekkoMode;

    if(program['import'])
      return 'importer';
    else if(program.backtest)
      return 'backtest';
    else
      return 'realtime';
  },
  gekkoModes: function() {
    return [
      'importer',
      'backtest',
      'realtime'
    ]
  },
  setGekkoEnv: function(env) {
    _gekkoEnv = env;
  },
  gekkoEnv: function() {
    return _gekkoEnv || 'standalone';
  },
  launchUI: function() {
    if(program['ui'])
      return true;
    else
      return false;
  },
  getStartTime: function() {
    return startTime;
  },
}

// NOTE: those options are only used
// in stand alone mode
program
  .version(util.logVersion())
  .option('-c, --config <file>', 'Config file')
  .option('-b, --backtest', 'backtesting mode')
  .option('-i, --import', 'importer mode')
  .option('--ui', 'launch a web UI')
  .parse(process.argv);

// make sure the current node version is recent enough
if(!util.recentNode())
  util.die([
    'Your local version of Node.js is too old. ',
    'You have ',
    process.version,
    ' and you need atleast ',
    util.getRequiredNodeVersion()
  ].join(''), true);

module.exports = util

```
### 試したこと
■コマンドプロンプトより下記コマンドを実行
   $ node gekko ui -c sample-config.js
   $ node gekko ui --config sample-config.js
   $ node gekko ui -c C:\Users\***\Downloads\gekko-develop\sample-config.js
   $ node gekko ui --config C:\Users\***\Downloads\gekko-develop\sample-config.js

### 補足情報（FW/ツールのバージョンなど）

ここにより詳細な情報を記載してください。
Node.jsのバージョン:16.14.2
OSのバージョン:Win10 Pro 21H2 64bitOS


node.jsアプリがコマンドプロンプトから起動しない。

Python初心者です。
bitflyerのAPIを使って、bitflyerの残高を取得したいです。

ネットの記事を参考に、一応残高を取得することは出来たのですが、保有していないコインの情報も一緒に取得してしまうので、amountが０じゃなかったらという条件付きで要素を取り出したいです。

一応自分でも書いてみましたが、SyntaxError: invalid syntaxになってしまいました。

どのように書き換えれば、保有しているコインの情報だけを(amountが０でない）要素を取得できるでしょうか。
開発環境はpython3.8.8です。jupyter notebookを使って書いていますが、Flaskを使ってWebアプリケーション形式にすることを想定しています。
個人情報保護のため、API_KEYとSECRETは削除しています！

＊追記情報＊
HTMLのformからvalueを受けとって、受け取った値によって条件分岐させる構造です。
get_balanceという関数を同ファイルに書いて、イベントが起こった時に呼び出す形になっています。
データを取得に成功したらHTMLに表示させるつもりなので、取得した値は変数に入れたいです。

```Python
import pybitflyer
import time
from datetime import datetime
from pytz import timezone
from dateutil import parser

BALANCE_KEYS = ["currency_code",
                "amount",
                "available"]

API_KEY = ""
API_SECRET = ""


if __name__ == '__main__':
    api = pybitflyer.API(api_key = API_KEY, api_secret = API_SECRET)

    balances = api.getbalance(product_code="BTC_JPY")

    for balance in balances:
        for balance_key in BALANCE_KEYS:
            if(BALANCE_KEY[1]=!0)
            print(balance_key + " : " + str(balance[balance_key]))
        print("=================================================")



``````Python
コード
```

import pybitflyer
from flask import Flask, render_template,request
import time
from datetime import datetime
import json
from dateutil import parser
from pytz import timezone



BASE_URL ="https://api.bitflyer.jp"
url = BASE_URL + "POST /v1/me/sendchildorder"

API_KEY = ""
API_SECRET =""
api = pybitflyer.API(API_KEY,API_SECRET)



nounce =str(int(time.time()))

app = Flask(__name__)

#残高を取得する関数
def get_balance():
   
    BALANCE_KEYS =["currency_code",
            "amount",
            "available"]

    balances =api.getbalance(product_code="BTC_JPY")
  
    for balance in balances:
        if balance ["amount"] == 0:
            continue
        for balance_key in BALANCE_KEYS:
            print(balance_key + " : " + str(balance[balance_key]))
        print("=================================================")

  
@app.route("/order",methods=["POST"])
#受け取った値に応じて関数を呼び出し
def receive_market():
    order_type = request.form.get('order_type')
    if order_type == "buy_market": 
        #成行買い
        buy_btc=api.sendchildorder(
    
                            product_code ="XRP_JPY",
                             child_order_type="MARKET",
                             side="BUY",
                             size=0.1,
                             minute_to_expire=1000,
                             time_in_force="GTC"
                             )

    elif order_type == "sell_market":
      #成行売り
     sell_btc=api.sendchildorder(
          
                            product_code ="XRP_JPY",
                             child_order_type="MARKET",
                             side="SELL",
                             size=0.1,
                             minute_to_expire=1000,
                             time_in_force="GTC"
       
    elif order_type =="get_balance":
     get_balance()
```


```エラー文
if balance ["amount"] == 0:
TypeError: string indices must be integers

```

pythonでリスト要素の一部を取得

CryptowatchというサイトのAPIを使用し、
bitflyerという取引所から過去のローソク足データを取得したく。
下記コード（１分足のローソク足データを取得）を実行したところ、
★で、10日前からの1分足ローソク足データを指定したにも関わらず
一度に約6000程度（= つまり4日分程度）の１分足ローソク足データしかCSV保存できません。

取引所のデータベース上に存在する すべての １分足ローソク足のデータ（つまり、存在する最古のデータ～現在のデータ）
を取得するには
どのようにコードを書き換えればよいでしょうか。
是非アドバイスをお願いいたします。

ちなみに、cryptowatchのAPI使用方法については、[こちらのQiita](https://qiita.com/iw_at_t/items/73e3201aa091a04ff248#marketsexchangepairohlc------%E3%83%AD%E3%83%BC%E3%82%BD%E3%82%AF%E8%B6%B3--)に掲載されています。


```
import requests
import time
import pandas as pd
from datetime import datetime

# *************************************************************************
# 関数ローソク足のOpen, High, Low, Closeを取得する関数
def get_OHLC(before, after):
    url = 'https://api.cryptowat.ch/markets/bitflyer/btcjpy/ohlc'
    query = {
        'periods': 60,
        'before': before,
        'after': after,
    }
    res = requests.get(url, params=query).json()['result']['60']
    return res


# unixtime(ミリ秒)を日時に変換
def convert_unix(unixtime):
    return datetime.fromtimestamp(unixtime)


unixTime = lambda y, m, d, h: int(time.mktime(datetime(y, m, d, h).timetuple()))

now = datetime.now()
y, m, d, h = now.year, now.month, now.day, now.hour


data = get_OHLC(unixTime(y, m, d, h), unixTime(y, m, d - 10, h))　　　　★
print(data)

Time, Open, High, Low, Close, Volume, UTCTime = [], [], [], [], [], [], []

# *************************************************************************
# Unix→UTCへ変換
unix = [x[0] for x in data]
print("unix : ", unix)

YYYYMMDD = []
for j in unix:
    yyyymmdd = convert_unix(j)
    print(str(yyyymmdd))
    YYYYMMDD.append(str(yyyymmdd))
print(YYYYMMDD)

for i in data:
    # print(i)
    Time.append(i[0])
    Open.append(i[1])
    High.append(i[2])
    Low.append(i[3])
    Close.append(i[4])
    Volume.append(i[5])
    UTCTime.append(i[6])

pd.DataFrame({'time': Time, 'open': Open, 'high': High, 'low': Low, 'close': Close, 'volume': Volume,
              'UTCTime': YYYYMMDD}).to_csv('price.csv')


```

bitFlyer API