int i = iBarShift(_Symbol,PERIOD_CURRENT,startTime);
string nm = _Symbol+"_Inputs.csv";
int h = FileOpen(nm,FILE_CSV|FILE_WRITE|FILE_COMMON,";");
double d[2];
while (i > 0) {
d[0]=iСustom(_Symbol,PERIOD_CURRENT,"Ind_1",0,i);
d[1]=iСustom(_Symbol,PERIOD_CURRENT,"Ind_2",0,i);
FileWrite(h,d[0],d[1]);
i--;
}
FileClose(h);
import os, time
import datetimeas dt
from json import loads, dump
from random import randint
import numpy as np
from Classes import date_time, Bar
import Functions
import MetaTrader5 as mt5
N = 1000 # количество отсчётов, сохраняемых в файлах котировок
N_sd_sell_max = 3 # максимальное количество сделок типа sell по одному инструменту
N_sd_buy_max = 3 # максимальное количество сделок типа buy по одному инструменту
volume = 0.01 # объём сделок
account_demo = ['Alpari-MT5-Demo', 12345678, 'password']
work_account = account_demo
work_catalog = 'Z:\\fx_for_forum\\fx\\'
instruments = ['EURUSD_i', 'GBPUSD_i', 'EURGBP_i', 'USDCHF_i', 'USDCAD_i', 'USDJPY_i']
def terminal_init(path_to_terminal, account):
'''
Функция осуществляет соединение с терминалом MT5
'''
if mt5.initialize(path_to_terminal, server=account[0], login=account[1], password=account[2]):
str1 = ' - соединение с терминалом {} билд {} установлено'
print(date_time.now().nice_view, str1.format(mt5.terminal_info().name, mt5.version()[1]))
return True
else:
print(date_time.now().nice_view, ' - соединение с терминалом установить не удалось')
return False
def terminal_done():
'''
Функция завершает соединение с терминалом MT5
'''
try:
mt5.shutdown()
print('\n' + date_time.now().nice_view, ' - соединение с терминалом успешно завершено')
except:
print('\n' + date_time.now().nice_view, ' - соединение с терминалом завершить не удалось')
def dt_stamp_from_M5_view(M5_view):
return date_time(int(M5_view[0:4]), int(M5_view[4:6]), int(M5_view[6:8]), int(M5_view[8:10]), int(M5_view[10:12]))
def pips_definer(instrument):
'''
Функция возвращает величину пипса для инструмента, например для EURUSD - 0.0001, для USDJPY - 0.01
'''
if instrument in ['EURUSD_i', 'GBPUSD_i', 'EURGBP_i', 'USDCHF_i', 'USDCAD_i']:
return0.0001
elif instrument in ['USDJPY_i']:
return0.01else:
return None
def save_prices_to_file(instrument, n=100):
'''
Функция принимает инструмент, количество отсчётов цены n в таймфрейме М5,
и сохраняет в файл (только сформировавшиеся полностью бары, время соответствует времени закрытия (!) бара)
'''
w = pips_definer(instrument)
tochn = int(abs(np.log10(w))+1)
path_file = os.path.join(work_catalog, instrument+'.txt')
bars = mt5.copy_rates_from_pos(instrument, mt5.TIMEFRAME_M5, 0, n+1) # в случае ошибки mt5.copy_rates_from_pos возвращает None
try:
f = open(path_file, 'w')
for i in range(0, n+1):
bar = bars[i]
dt_stamp = date_time.fromtimestamp(bar[0], dt.timezone.utc) + dt.timedelta(hours=1, minutes=5)
open_ = str(round(bar[1], tochn))
high_ = str(round(bar[2], tochn))
low_ = str(round(bar[3], tochn))
close_ = str(round(bar[4], tochn))
if i != n:
f.write(dt_stamp.M5_view + ' ' + open_ + ' ' + high_ + ' ' + low_ + ' ' + close_ + '\n')
f.close()
print(date_time.now().nice_view, ' - котировки {} успешно записаны в файл'.format(instrument))
except:
print(date_time.now().nice_view, ' - котировки {} записать в файл не удалось'.format(instrument))
def read_file_with_prices(catalog, instrument):
'''
Функция принимает каталог, и наименование инструмента, читает в указанном каталоге файл с ценами для указанного инструмента
(формат данных: отсчёт времени в виде строки формата M5_view, open, high, low, close), проверяет цены на целостность данных.
Функция возвращает или массив ndarray (если всё успешно), или строку 'no data' (если данные не прочитались, или неполны)
'''
path_file = os.path.join(catalog, instrument+'.txt')
try:
f = open(path_file, 'r')
ndarray___with_prices_for_instrument = np.loadtxt(f, delimiter=' ', dtype='float64')
f.close()
except:
print(date_time.now().nice_view + ' - Файл с котировками для {} прочитать не удалось'.format(instrument))
return 'no data'
# проверка данных на целостность
timedelta_5 = dt.timedelta(minutes=5)
nx = ndarray___with_prices_for_instrument.shape[0]
for i in range(1, nx):
dt_stamp_i = dt_stamp_from_M5_view(str(int(ndarray___with_prices_for_instrument[i, 0])))
dt_stamp_im1 = dt_stamp_from_M5_view(str(int(ndarray___with_prices_for_instrument[i-1, 0])))
t_delta = dt_stamp_i - dt_stamp_im1
if t_delta != timedelta_5:
if t_delta >= dt.timedelta(hours=47) and t_delta <= dt.timedelta(hours=50):
pass # разрыв данных с вечера пятницы до понедельника
else:
t1 = ' - Котировки для {} неполны, и не будут переданы на выполнение расчётов\nИменно - ошибка при {}'
print((date_time.now().nice_view + t1).format(instrument, dt_stamp_im1.M5_view))
return 'no data'
return ndarray___with_prices_for_instrument
def read_all_files_with_prices(catalog, instruments):
'''
Функция принимает каталог, и список инструментов, читает в указанном каталоге файлы с ценами для указанных инструментов
с использованием функции read_file_with_prices.
Функция возвращает словарь prices_for_all_instruments с котировками по всем инструментам.
В этом словаре ключи - наименования инструментов, значения - словари с котировками по одному соответствующему инструменту.
В словарях с котировками по одному инструменту ключи - отсчёты даты-времени (класс date_time), значения - бары (класс bar),
кроме того предусмотрены ключи:
- 'is_data' - значение по ключу - True, если котировки в наличии, False - если функция чтения из файла вернула 'no data',
- 'instrument' - значение по ключу - инструмент (str);
- 'prices' - значение по ключу - массив котировок по инструменту (numpy.ndarray)
'''
dict___with_prices_for_all_instruments = {}
for instrument in instruments:
w = pips_definer(instrument)
ndarray___with_prices_for_instrument = read_file_with_prices(catalog, instrument)
dict___with_prices_for_instrument = {}
if type(ndarray___with_prices_for_instrument) == type('no data'):
dict___with_prices_for_instrument['is_data'] = False
else:
dict___with_prices_for_instrument['is_data'] = True
dict___with_prices_for_instrument['instrument'] = instrument
dict___with_prices_for_instrument['prices'] = ndarray___with_prices_for_instrument
for i in range(0, ndarray___with_prices_for_instrument.shape[0]):
dt_stamp = dt_stamp_from_M5_view(str(int(ndarray___with_prices_for_instrument[i, 0])))
dict___with_prices_for_instrument[dt_stamp] = Bar(instrument, 5, dt_stamp,
ndarray___with_prices_for_instrument[i, 1],
ndarray___with_prices_for_instrument[i, 3],
ndarray___with_prices_for_instrument[i, 2],
ndarray___with_prices_for_instrument[i, 4], w)
dict___with_prices_for_all_instruments[instrument] = dict___with_prices_for_instrument
return dict___with_prices_for_all_instruments
def main(N):
'''
Главная функция, обеспечивающая в бесконечном цикле связь с терминалом,
сохранение котировок, и запуск функции, осуществляющей торговлю
'''
dt_start = date_time.now()
dt_write = dt_stamp_from_M5_view(dt_start.M5_view) + dt.timedelta(minutes=5, seconds=10)
print('\n' + dt_start.nice_view, ' - начал работу, бездействую до ' + dt_write.nice_view + '\n')
timedelta_sleep = dt_write - date_time.now()
time.sleep(timedelta_sleep.seconds)
while True:
# установка соединения с MetaTrader5
if terminal_init(os.path.join('C:\\', 'Program Files', 'Alpari MT5', 'terminal64.exe'), work_account):
# запись цен в файлы: для всех инструментов, N отсчётов
if (dt.datetime.now() - dt_write) < dt.timedelta(seconds=10):
print('\n' + date_time.now().nice_view + ' - начинаю запись цен в файлы для всех инструментов')
for instrument in instruments:
save_prices_to_file(instrument, N)
# пауза 5 секунд после записи файлов с ценами, возможно необходимых для открытия в Mathcad,
# или ещё зачем, если в них нет нужды, желающие могут переписать код, исключив бессмысленную
# последовательность записи файлов, и затем чтения файлов, сразу сформировав нужную им структуру данных
time.sleep(5)
# определяем значение последнего отсчёта времени, который должен быть в файлах котировок, если они актуальны
# (в выходные дни это будет не так, а в будни, пока рынок открыт - так)
fx_dt_stamp_now = dt_stamp_from_M5_view(date_time.now().M5_view)
print('\n\n'+date_time.now().nice_view, '- начинаю вычисления для отсчёта времени {}'.format(fx_dt_stamp_now.M5_view))
# получаем словарь с ценами для всех инструментов
dict___with_prices_for_all_instruments = read_all_files_with_prices(work_catalog, instruments)
# демонстрация актуальности котировок,
# поскольку сейчас выходной, то последний отсчёт времени в файлах данных не совпадает с текущим, не суть
for instrument in instruments:
if dict___with_prices_for_all_instruments[instrument]['is_data']:
str1 = 'Последний отсчёт в файле с ценами для {}: {}'
print(str1.format(instrument, str(int(dict___with_prices_for_all_instruments[instrument]['prices'][N-1, 0]))))
# завершение соединения с MetaTrader5
terminal_done()
# определение параметров ожидания до следующего выполнения тела цикла
dt_start = date_time.now()
dt_write = dt_stamp_from_M5_view(dt_start.M5_view) + dt.timedelta(minutes=5, seconds=10)
timedelta_sleep = dt_write - dt_start
print(date_time.now().nice_view + ' - засыпаю до {}\n\n\n\n\n'.format(dt_write.nice_view))
time.sleep(timedelta_sleep.seconds)
if __name__ == '__main__':
main(N)
我的观点是，Python与MT5的整合还没有完成。你不能直接获得指标值
读取数据到python
该主题的目的就像五分钱一样简单：让每个人都能在Python中开始算法交易，只需复制一些代码，如初始化与终端的通信、请求报价、要求服务器打开或关闭交易等等，等等。只集中在逻辑上，而且是用一种极其容易使用的语言。
对...逻辑正是算法交易所缺少的--在 "所有来者 "插入代码片段并进入真正的交易之前，你需要测试交易策略的逻辑。
不管怎样，祝你在 "非神话 "的目标上好运。
)))
不需要将价格保存到文件中的人将重写一下代码，不做 "写到文件-从文件中读取"，而只是做他们想要的数据结构。这里主要是展示原始的东西，对于那些愿意迈出第一步的人来说。
然而，那些已经熟悉诸如列表、图元、字典等概念的人。
我建议用函数read_all_files_with_prices 从价格文件中读取，这将触发函数read_file_with_prices 来读取每个工具的价格文件。让read_file_with_prices 函数 返回数组numpy.ndarray，其行和列对应于原始价格文件（如果价格被成功读取并检查了数据的完整性，每个元素类型为numpy.float64），或者如果没有读取数据或不完整，则返回字符串'no data' 。
让 read_all_files_with_prices 函数 返回一个包含所有工具的报价的字典 。 假设这个字典中的键是乐器的名称，而值是带引号的一个相应乐器的字典。在带引号的字典中，一个符号的键是date_time，值是bar（类bar）；此外，我建议提供键:
is_data': 键值 - 如果有引号则为真，如果从文件中读取返回'无数据'则为假。
'仪器'：键值 - 仪器（str）。
'prices': key-value - 工具的价格数组（numpy.ndarray）。
简而言之，这就是我建议的数据结构。
Python代码最好以IDE/编辑器/网站的截图形式放置。
局部缺乏高亮，至少是代码注释的高亮，使其可读性很差，它与正文融为一体。
增加了读取文件和创建上述数据结构 的函数。
Python代码最好以IDE/编辑器/网站的截图形式放置。
局部缺乏高亮，至少对代码注释而言，使其可读性很差，它与正文融为一体。
但它可以被复制并在IDE中打开，但从图像中可以手动重新输入，除了...
上图所示程序的工作。
基本上，几乎所有的东西都准备好了，可以开始分析数据，做出并执行交易决策。
但它可以被复制并在IDE中打开，而图片可以手动输入...
我不认为有人会费力地复制和粘贴代码......这里没有人需要它。
来阅读和讨论，是的。捡起一些好奇的东西或给予一些暗示。而且我不认为我会在IDE中拖动它。人们在论坛上发布代码供他人阅读，如果要使用这些代码，可以附上代码或链接到资源库（或将它们结合起来）。
但这让人分心。
将以下代码放入Functions.py文件，这是一个计算SMA的函数
我需要参数d和k来进行时间转移，而不是点，我们将它们设置为零。
我会想出一些简单的哑巴逻辑，比如。
对于每个工具，我们计算滞后于样本之间z=100间隔的SMA，即s=1+2*z=201顺序的SMA。
如果市场上没有交易，或其数量（对某一符号）低于允许的数量（分别为卖出和买入）。
如果目前价格高于SMA(201)30点或更多 - 开立一个卖出交易，SL=TP=50点。
如果目前价格低于SMA(201)30点或更多 - 开立一个买入交易，SL=TP=50点。
如果在任何时候，交易的利润 达到20个点--关闭它，不需要等待SL或TP的关闭。
让我们以这样的交易为例来实施。从交易的角度看，很简单，很傻，但事情的本质是执行。
我建议为开仓和平仓交易提供这样的功能。