class_docstr: base level of API control
  select data pipeline here, Redis/Kafka/...
  interface preserved for API class
class_docstr_tok: ["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",
      ssl=False,
      ssl_certfile=None,
      ssl_keyfile=None,
      ssl_ca_certs=None,
  ):
      self.name = name
      self.host = host if host else "localhost"
      self.port = port if port else "6379"
  
      if not ssl:
          self.db = redis.StrictRedis(
              host=self.host, port=self.port, db=0
          )
      else:
          # TODO none for self-signed key
          self.db = redis.StrictRedis(
              host=self.host,
              port=self.port,
              db=0,
              ssl=True,
              ssl_cert_reqs="none",
              ssl_certfile=ssl_certfile,
              ssl_keyfile=ssl_keyfile,
              ssl_ca_certs=ssl_ca_certs,
          )
  
      try:
          self.db.xgroup_create(name, "serving")
      except Exception:
          print("redis group exist, will not create new one")
  
imports: import redis
  import time
  from zoo.serving.schema import *
  import httpx
  import json
  import uuid
label_desc: Use image node_id 1 to create a new API object  with example: obj = API(host, port, name, ssl, ssl_certfile, ssl_keyfile, ssl_ca_certs)