LinuxForHealth/connect

Storage Driver Support

Opened this issue · 0 comments

This epic supports storing input messages outside of LinuxForHealth Connect's kafka topics within a storage system. Storage systems include:

  • Object Storage (using minio)
  • IPFS
  • RDBMS

Storage systems are supported through the use of a storage driver "interface" which defines the basic operations requires to store and fetch a message from a system.

def store(input_message: Any) -> str:
       # input_message is an EDI Model
       # return type is the URI to the message within the storage system
       pass
 
def fetch(uri: str) -> Any:
       # uri is the storage system uri
       # returns the input message as an EDI model
       pass