adelorenzo/stable
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

added additional data to be persisted

Browse Source
This commit is contained in:
Gert Wohlgemuth 2018-06-05 17:31:05 -07:00
parent 020886324b
commit ede1e20526
2 changed files with 8 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
freqtrade/aws/backtesting_lambda.py
View File

@ -215,7 +215,9 @@ def _store_aggregated_data(interval, name, result, timerange, user):
"losses": row[6],
"wins": row[5],
"duration": row[4],
"profit_percent": row[2]
"profit_percent": row[2],
"strategy": name,
"user": user
}
print(data)
@ -238,7 +240,10 @@ def _store_trade_data(interval, name, result, timerange, user):
"profit_percent": row['profit_percent'],
"profit_stake": row['profit_BTC'],
"entry_date": row['entry'].strftime('%Y-%m-%d %H:%M:%S'),
"exit_date": row['exit'].strftime('%Y-%m-%d %H:%M:%S')
"exit_date": row['exit'].strftime('%Y-%m-%d %H:%M:%S'),
"strategy": name,
"user": user
}
print(data)

19
freqtrade/aws/trade.py
View File

@ -15,24 +15,7 @@ def store(event, context):
for x in event['Records']:
if 'Sns' in x and 'Message' in x['Sns']:
data = json.loads(x['Sns']['Message'], use_decimal=True)
table = get_strategy_table()
response = table.query(
KeyConditionExpression=Key('user').eq(data['user']) &
Key('name').eq(data['strategy'])
)
if "Items" in response and len(response['Items']) > 0:
item = response['Items'][0]
data['strategy'] = {
"name": item['name'],
"user": item['user'],
"public": item['public']
}
get_trade_table().put_item(Item=data)
get_trade_table().put_item(Item=data)
def submit(event, context):