Я не могу захватить / напечатать данные на экземпляре pull, используя обычный шаблон нулевого толкания / вытягивания - PullRequest
Новая
       32

Я не могу захватить / напечатать данные на экземпляре pull, используя обычный шаблон нулевого толкания / вытягивания

0 голосов
/ 01 декабря 2019

У меня трудные времена, чтобы захватить и напечатать данные, которые успешно переданы на провод. Я установил простую Push-Pull-архитектуру с Metatrader 4, действующим как producer, а Python-сервер, действующим как consumer.

Когда дело доходит до захвата и печати данных, я просто не могу этого добиться.

Это мой push-экземпляр, который работает просто отлично:

Metatrader 4 zeroMQ push-экземпляр: 

#include <Zmq/Zmq.mqh>

// EA plot settings

extern string PROJECT_NAME = "Dashex.Feeder";
extern string ZEROMQ_PROTOCOL = "tcp";
extern string HOSTNAME = "localhost";
extern int PUSH_PORT = 32225;

extern string t0 = "--- Feeder Parameters ---";
input string DID = "insert your DID here";
extern string t1 = "--- ZeroMQ Configuration ---";
extern bool Publish_MarketData = false;

// ZeroMQ environment //

// CREATE ZeroMQ Context
Context context(PROJECT_NAME);

// CREATE ZMQ_PUSH SOCKET
Socket pushSocket(context, ZMQ_PUSH);

string Publish_Symbols[7] = {
   "EURUSD","GBPUSD","USDJPY","USDCAD","AUDUSD","NZDUSD","USDCHF"
};

//+------------------------------------------------------------------+
//| Expert initialization function                                   |
//+------------------------------------------------------------------+

int OnInit()
  {
//---

   EventSetTimer(1);     // Set Millisecond Timer to get client socket input

   context.setBlocky(false);

   // Send responses to PULL_PORT that client is listening on.
   Print("[PUSH] Connecting MT4 Server to Socket on Port " + IntegerToString(PUSH_PORT) + "..");
   pushSocket.connect(StringFormat("%s://%s:%d", ZEROMQ_PROTOCOL, HOSTNAME, PUSH_PORT));

   pushSocket.setSendHighWaterMark(1);
   pushSocket.setLinger(0);   

//---
   return(INIT_SUCCEEDED);
  }

//+------------------------------------------------------------------+
//| Expert deinitialization function                                 |
//+------------------------------------------------------------------+
void OnDeinit(const int reason)
{
//---

   Print("[PUSH] Disconnecting MT4 Server from Socket on Port " + IntegerToString(PUSH_PORT) + "..");
   pushSocket.disconnect(StringFormat("%s://%s:%d", ZEROMQ_PROTOCOL, HOSTNAME, PUSH_PORT));

   // Shutdown ZeroMQ Context
   context.shutdown();
   context.destroy(0);

   EventKillTimer();
}
//+------------------------------------------------------------------+
//| Expert tick function                                             |
//+------------------------------------------------------------------+
void OnTimer()
{
   /*
      Use this OnTimer() function to send market data to consumer.
   */
   if(!IsStopped() && Publish_MarketData == true)
   {
      for(int s = 0; s < ArraySize(Publish_Symbols); s++)
      {

         string _tick = GetBidAsk(Publish_Symbols[s]);
         Print("Sending " + Publish_Symbols[s] + " " + _tick + " to PUSH Socket");
         ZmqMsg reply(StringFormat("%s %s", Publish_Symbols[s], _tick));
         pushSocket.send(reply, true);
      }
   }
}
//+------------------------------------------------------------------+

string GetBidAsk(string symbol) {

   MqlTick last_tick;

   if(SymbolInfoTick(symbol,last_tick))
   {
       return(StringFormat("%f;%f", last_tick.bid, last_tick.ask));
   }

   // Default
   return "";
}

Как данныепроталкивается к проводу (массив строк, фрагмент кода выше): 

         string _tick = GetBidAsk(Publish_Symbols[s]);
         Print("Sending " + Publish_Symbols[s] + " " + _tick + " to PUSH Socket");
         ZmqMsg reply(StringFormat("%s %s", Publish_Symbols[s], _tick));
         pushSocket.send(reply, true);

enter image description here

Клиент на стороне Python, которыйне захватывает и не печатает данные с провода: 

import zmq
import time
from time import sleep

context = zmq.Context()
zmq_socket = context.socket(zmq.PULL)
zmq_socket.bind("tcp://*:32220")
time.sleep(1)

while True:

    def pull_MT4():

        try:
            msg = zmq_socket.recv_string()
            print(msg)
            return msg
        except zmq.error.Again:
            print("\nResource timeout.. please try again.")
            sleep(0.000001)

        return None

Вывод на консоль без печатных данных: - (

enter image description here

1 Ответ

1 голос
/ 01 декабря 2019

Внутри while True вы только снова и снова определяете функцию pull_MT4, но вы никогда не выполняете эту функцию - вы никогда не используете pull_MT4() для ее запуска.

Вы должны использовать этот код непосредственно в цикле (без определения функции и без return) 

while True:
    try:
        msg = zmq_socket.recv_string()
        print(msg)
    except zmq.error.Again:
        print("\nResource timeout.. please try again.")
        sleep(0.000001)

или вы должны определить функцию перед циклом и выполнить ее внутри цикла 

def pull_MT4(): # define function
    try:
        msg = zmq_socket.recv_string()
        print(msg)
        return msg
    except zmq.error.Again:
        print("\nResource timeout.. please try again.")
        sleep(0.000001)
    return None

while True:
    pull_MT4() # execute function
...