class_docstr: base level of API control
  select data pipeline here, Redis/Kafka/...
  interface preserved for API class
code: def __init__(self, host=None, port=None, name="serving_stream"):
      self.name = name
      self.host = host if host else "localhost"
      self.port = port if port else "6379"
  
      self.db = redis.StrictRedis(host=self.host, port=self.port, db=0)
      try:
          self.db.xgroup_create(name, "serving")
      except Exception:
          print("redis group exist, will not create new one")
  
imports: import redis
  import time
  from bigdl.serving.schema import *
  import httpx
  import json
  import uuid
  from bigdl.serving.log4Error import invalidInputError
label_desc: Use image node_id 1 to create a new API object  with example: obj = API(host, port, name)