class_docstr: A monitor process for monitoring worker log files.
docstr: Initialize the log monitor object.
docstr_tok: ["Initialize","the","log","monitor","object","."]
code: def __init__(
      self,
      driver_ip,
      driver_port,
      log_path,
      thread_stopped,
      partition_id,
  ):
      """Initialize the log monitor object."""
      from bigdl.dllib.utils.utils import get_node_ip
  
      self.ip = get_node_ip()
      self.log_path = log_path
      self.partition_id = partition_id
      import zmq
  
      context = zmq.Context()
      self.socket = context.socket(zmq.REQ)
      self.socket.connect("tcp://{}:{}".format(driver_ip, driver_port))
      logger.info(
          "Connected log server on {}:{}".format(driver_ip, driver_port)
      )
      self.thread_stopped = thread_stopped
      self.log_fd = None
  
file_path: BigDL/python/orca/src/bigdl/orca/learn/log_monitor.py
imports: import logging
  import os
  import time
  from bigdl.dllib.utils.log4Error import *
label_desc: Use image node_id 1 to create a new LogMonitor object  with example: obj = LogMonitor(driver_ip, driver_port, log_path, thread_stopped, partition_id)