使用 MQL5 将 OHLC 值从 Python API 集成到 MT5

Question

我已经从 iqoption 中获得了 OHLC 值，并试图找到一种将其用于 MT5 的方法。
以下是我如何获得这些值：

import time
from iqoptionapi.stable_api import IQ_Option
I_want_money=IQ_Option("email","password")
goal="EURUSD"
print("get candles")
print(I_want_money.get_candles(goal,60,111,time.time()))

以上代码库在这里：iqoptionapi

行：I_want_money.get_candles(goal,60,111,time.time())输出json为：Output of the command

现在我在输出中得到 json，所以它像 API 一样工作，我猜是这样。

同时，我尝试在 MT5 中创建自定义交易品种 iqoption。现在我只想将 OHLC 的数据从 API 添加到它，这样它将继续从 Iqoption 获取数据并在图表 window 上显示自定义交易品种 [=15] 的图表=].

但我无法在自定义交易品种中加载它。请帮助我。

已编辑

这是来自 iqoption 的实时流数据代码：

from iqoptionapi.stable_api import IQ_Option
import logging
import time
logging.basicConfig(level=logging.DEBUG,format='%(asctime)s %(message)s')
I_want_money=IQ_Option("email","password")
I_want_money.start_candles_stream("EURUSD")
thread=I_want_money.collect_realtime_candles_thread_start("EURUSD",100)
I_want_money.start_candles_stream("USDTRY")
thread2=I_want_money.collect_realtime_candles_thread_start("USDTRY",100)
time.sleep(3)
#Do some thing
ans=I_want_money.thread_collect_realtime.items()
for k, v in ans:
    print (k, v)
I_want_money.collect_realtime_candles_thread_stop(thread)
I_want_money.stop_candles_stream("EURUSD")
I_want_money.collect_realtime_candles_thread_stop(thread2)
I_want_money.stop_candles_stream("USDTRY")

Answer 1

经过二读你写的（和编辑的）我可以看到你想要：

一个与 iqoption 同步的符号 [通过您的代理/远程]
交易品种可用于回测
符号可用于屏幕 live/strategy/indicator 运行

这意味着 strategy/indicator 之外的操作，MT 平台不允许以自动方式进行 - 您可以通过提供数据包、将其解析为 CSV 并导入自定义交易品种创建器来手动实现。有据可查 here。

不幸的是，您选择了一个设计代表独立策略和指标的平台，更多的是初学者而不是认真对待它的专业人士。

参考我提供的link自己看吧。官方文档声明您可以通过 mql ref 创建自定义交易品种，但即使他们在前言中声明，它允许第 3 方提供商 - 它没有在其他任何地方引用，也没有显示任何集成可能性。

custom indicators

custom symbol properties

Answer 2

好的，你需要
1. 收到broker的feed(希望你成功了)
2. 写入文件
**（两者 - python）**
3. 读取并解析
4. 将其添加到历史centre/marketWatch
**（两者 - mt5）**

因此，您在之后接收到字符串形式的数据 I_want_money.get_candles(goal,60,111,time.time()) 这个字符串可能是 json 或 json-array.
重要的问题当然是你要放置数据的路径。 MQL45 专家只能访问两个文件夹（如果不应用 dll）： C:\Users\MY_NAME_IS_DANIEL_KNIAZ\AppData\Roaming\MetaQuotes\Terminal\MY_TERMINAL_ID_IN_HEX_FORMAT\MQL4\Files 和 C:\Users\MY_NAME_IS_DANIEL_KNIAZ\AppData\Roaming\MetaQuotes\Terminal\Common\Files 在后一种情况下，您需要使用 const int handle=FileOpen(,|*| FILECOMMON);

为了解析 json，您可以使用 jason.mqh https://www.mql5.com/en/code/13663 库（其他的很少），但据我所知它有一个错误：它无法解析数组对象的正确。为了克服这个问题，我建议将每个刻度写在单独的一行中。最后，您将随机从 python 应用程序接收数据，并将其写入 Common 或直接文件夹。 MT5 机器人将读取并删除。为避免混淆，最好保证文件具有唯一名称。随机 (random.randint(1,1000)) 或日期时间的毫秒数都可以提供帮助。

到目前为止，您有 python 代码：

 receivedString = I_want_money.get_candles(goal,60,111,time.time())  
 filePath = 'C:\Users\MY_NAME_IS_DANIEL_KNIAZ\AppData\Roaming\MetaQuotes\Terminal\MY_TERMINAL_ID_IN_HEX_FORMAT\MQL4\Files\iqoptionfeed'  
 fileName = os.path.join(filePath,"_"+goal+"_"+str(datetime.now())+".txt")   
 file = open(fileName, "w")  
 for string_ in receivedString:  
     file.write(string_)  
 file.close()

如果您创建了一个线程，每次您收到线程的回答时，您都会编写这样一个文件。

接下来，您需要 MT5 中的数据。最简单的方法就是遍历已有的文件，确保能读取再读取（不能读取则放弃）读取后删除，再对接收到的数据进行处理。最简单和快速的方法当然是使用 0MQ，但让我们在没有 dll 的情况下进行。为了读取文件，您需要设置一个可以尽可能快地工作的计时器，然后放手。由于您无法让 windows 应用休眠少于 15.6 毫秒，因此您的计时器应该休眠这个时间。

string path;
int OnInit()
  {
   EventSetMillisecondTimer(16);    
   path="iqoptionfeed\*";
  }
void OnDeinit(const int reason) {   EventKillTimer();   }

string _fileName;
long _search_handle;
void OnTimer()
  {
   _search_handle=FileFindFirst(path,_fileName);
   if(_search_handle!=INVALID_HANDLE)
      {
       do
         {
          ResetLastError();
          FileIsExist(_fileName);
          if(GetLastError()!=ERR_FILE_IS_DIRECTORY)
             processFile(path+_fileName);
         }
       while(FileFindNext(_search_handle,_fileName));
       FileFindClose(_search_handle);
      }
  }

这段代码循环文件夹并处理它设法找到的每个文件。现在读取文件（两个函数）并处理其中的消息：

void processFile(const string fileName)
  {
   string message;
   if(ReadFile(fileName,message))
      processMessage(message,fileName);
  }
bool ReadFile(const string fileName,string &result,const bool common=false)
  {
   const int handle = FileOpen(fileName,common?(FILE_COMMON|FILE_READ):FILE_READ);
   if(handle==INVALID_HANDLE)
     {
      printf("%i - failed to find file %s (probably doesnt exist!). error=%d",__LINE__,fileName,GetLastError());
      return(false);
     }
   Read(handle,result);
   FileClose(handle);
   if(!FileDelete(fileName,common?FILE_COMMON:0))
      printf("%i - failed to delete file %s/%d. error=%d",__LINE__,fileName,common,GetLastError());
   return(true);
  }
void Read(const int handle,string &message)
  {
   string text="";
   while(!FileIsEnding(handle) && !IsStopped())
     {
      text=StringConcatenate(text,FileReadString(handle),"\n");
     }
   //printf("%i %s - %s.",__LINE__,__FUNCTION__,text);
   message=text;
  }

最后但并非最不重要的：处理获得的文件。正如上面所建议的，每个新报价都有一个 json 格式的报价，由 \r\n.
分隔我们的目标是将它添加到符号中。为了解析 json，jason.mqh 是一个可用的解决方案，但您当然可以手动解析它。

void processMessage(const string message,const string fileName)
  {
   string symbolName=getSymbolFromFileName(fileName);
   if(!SymbolSelect(symbolName,true))
     {
      if(!CustomSymbolCreate(symbolName))
         return;
     }
   string lines[];
   int size=StringSplit(message,(ushort)'\n',lines);
   for(int i=0;i<size;i++)
     {
      if(StringLen(lines[i])==0)
        continue;
      CJAVal jLine(jtUNDEF,NULL);
      jLine.Deserialize(lines[i]);
      MqlTick mql;
      //here I assume that you receive a json file like " { "time":2147483647,"bid":1.16896,"ask":1.16906,"some_other_data":"someOtherDataThatYouMayAlsoUse" } "
      mql.time=(datetime)jLine["time"].ToInt();
      mql.bid=(double)jLine["bid"].ToDbl();
      mql.ask=(double)jLine["ask"].ToDbl();
      ResetLastError();
      if(CustomTicksAdd(symbolName,mql)<0)
          printf("%i %s - failed to upload tick: %s %s %.5f %.5f. error=%d",__LINE__,__FILE__,symbolName,TimeToString(mql.time),mql.bid,mql.ask,GetLastError()); 
     }
  }
string getSymbolFromFileName(const string fileName)
  {
   string elements[];
   int size=StringSplit(fileName,(ushort)'_',elements);
   if(size<2)
      return NULL;
   return elements[1];
  }

不要忘记添加调试信息，GetLastError() 的请求由于某种原因会出错。

这可以在后台测试器中使用吗？当然不是。首先，MQL 测试器不支持 OnTimer()。接下来，您需要一些历史记录才能使其成为运行。如果您没有任何历史记录——没有人可以帮助您，除非经纪人可以给您；最好的办法是立即开始收集和存储它，当项目准备就绪时（可能再过几个月），您将准备好并能够使用可用数据集测试和优化策略。您可以将收集的集合应用到测试器中（与 MQL4 相比，MQL5 实际上是算法交易开发的下一步），您可以手动或使用类似 tickDataSuite 及其 Csv2Fxt.ex4 文件的东西，该文件生成测试器可以读取和处理的 HST 二进制文件；无论如何，这是另一个问题，没有人能告诉您您的经纪人是否将他们的数据存储在某处以提供给您。

使用 MQL5 将 OHLC 值从 Python API 集成到 MT5

Integrating the OHLC value from Python API to MT5 using MQL5

python

metatrader5

mql5