dash_board-crypto/code.py at main · marcan-dev/dash_board-crypto · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
# import libraries
from cryptocomapi import CryptoComApi
import pandas as pd
pd.options.mode.chained_assignment = None
# to have not warning about pandas update like this:
# SettingWithCopyWarning: A value is trying to be set on a copy of a slice from a DataFrame.
#Try using .loc[row_index,col_indexer] = value instead
import cryptocom.exchange as cro
from binance.client import Client
import numpy as np

#### crypto.com ####


# my crypto
# Use an API to bring count from Crypto.com to Python
api = CryptoComApi(api_key="your api key", secret_key="your secret key")
all_asset = api.get_account()
df= pd.DataFrame.from_dict(all_asset['coin_list'])
# to not take locked asset at 0, but this line is not necessary
df1 = df.loc[df['locked'] != '0']
df1['normal'] = pd.to_numeric(df1['normal'])
df1['locked'] = pd.to_numeric(df1['locked'])
df1['quantity'] = df1.apply(lambda row: row['normal'] + row['locked'], axis=1)
df3 = df1.reindex(['coin','normal','locked', 'quantity'], axis=1)


# crypto price
# importation of actual price of the assets
asset = api.get_market_trades()


res = dict((k, asset[k]) for k in ['crousdt', 'vetusdt', 'thetausdt',
 'chzusdt', 'linkusdt', 'csprusdt', 'usdcusdt'])

res['CRO'] = res.pop("crousdt")
res['VET'] = res.pop("vetusdt")
res['THETA'] = res.pop("thetausdt")
res['CHZ'] = res.pop("chzusdt")
res['LINK'] = res.pop("linkusdt")
res['CSPR'] = res.pop("csprusdt")
res['USDC'] = res.pop("usdcusdt")
df0 = pd.DataFrame(res.items(), columns=['coin', 'price'])


# merge crypto price with own crypto assets
df4 = pd.merge(df3, df0, on='coin')

# add the total value of each coin
df4['value'] = df4.apply(lambda row: row['quantity'] * row['price'], axis=1)


#### binance ####
# do the same  with an other exchange, in this exemple, I use binance
# keys
api_key = 'your api key'
api_secret = 'your secret api'
client=Client(api_key,api_secret)

crypto = ['DOT', 'FTM', 'EGLD','BCD', 'USDT', 'USDC']
my_crypto = []
for i in range(len(crypto)):
    my_crypto.append(client.get_asset_balance(asset=crypto[i]))


df_bi = pd.DataFrame.from_dict(my_crypto)
df_bi['free'] = pd.to_numeric(df_bi['free'])
df_bi['locked'] = pd.to_numeric(df_bi['locked'])

df_bi['quantity'] = df_bi.apply(lambda row: row['free'] + row['locked'], axis=1)

#print(df_bi)
df_bi.rename(columns = {'asset':'coin', 'free':'normal'}, inplace = True)

# crypto price

asset = api.get_market_trades()
resu = dict((k, asset[k]) for k in ['dotusdt', 'ftmusdt', 'egldusdt','usdcusdt'])

resu['DOT'] = resu.pop("dotusdt")
resu['FTM'] = resu.pop("ftmusdt")
resu['EGLD'] = resu.pop("egldusdt")
resu['USDC'] = resu.pop("usdcusdt")


df0_bi = pd.DataFrame(resu.items(), columns=['coin', 'price'])

# merge df_bi and df0_bi
df_result_bi = pd.merge(df_bi, df0_bi, on='coin')

df_result_bi['value'] = df_result_bi.apply(lambda row: row['quantity'] * row['price'], axis=1)


# create the value "row usdt" because it is not in the dataframe crypto_price

row_usdt = df_bi.loc[df_bi['coin'] == 'USDT']

# add colums 'price' and 'value' to the dataframe
col_price = [1]

row_usdt['price'] = col_price
row_usdt['value'] = row_usdt.apply(lambda row: row['quantity'] * row['price'], axis=1)


# join datafram crypto.com and binance
df_all_rows = pd.concat([df_result_bi, df4])
df_all_rows = df_all_rows.append(row_usdt, ignore_index=True)

# add to row usdt price and value

df_bi = df_bi.append(row_usdt, ignore_index=True)


# delete the duplicated rows
#df_all_rows = df_all_rows.drop([5 , 6, 7])


# round all colums in the data frame
df_all_rows = df_all_rows.round(2)


df_result = df_all_rows.groupby(['coin']).sum()
print(df_result)

# create a var total to have the total crypto in USDT we have


# export to csv
df_result.to_csv(sep='.')