Airbyte Schema

        graph LR
O(Organization) -- RESOURCE --> W(Workspace)
O -- RESOURCE --> U(User)
O -- RESOURCE --> S(Source)
O -- RESOURCE --> D(Destination)
O -- RESOURCE --> T(Tag)
O -- RESOURCE --> C(Connection)
O -- RESOURCE --> Str(Stream)
W -- CONTAINS --> S
W -- CONTAINS --> D
W -- CONTAINS --> T
W -- CONTAINS --> C
C -- SYNC_FROM --> S
C -- SYNC_TO --> D
C -- TAGGED --> T
C -- HAS --> Str
U -- ADMIN_OF --> O
U -- ADMIN_OF --> W
U -- MEMBER_OF --> W
    

AirbyteOrganization

Provides details of a single organization for a user.

Ontology Mapping: This node has the extra label Tenant to enable cross-platform queries for organizational tenants across different systems (e.g., OktaOrganization, AWSAccount).

Field	Description
id	The organization UUID
name	The name of the organization
email	Contact email for the organization
firstseen	Timestamp of when a sync job first created this node
lastupdated	Timestamp of the last time the node was updated

Relationships

• Workspace, User, Source, Destination, Tag, Connection, Stream belong to an Organization.

  (:AirbyteOrganization)-[:RESOURCE]->(
      :AirbyteWorkspace,
      :AirbyteUser,
      :AirbyteSource,
      :AirbyteDestination,
      :AirbyteTag,
      :AirbyteConnection,
      :AirbyteStream
  )
  

• User is admin of an Organization

  (:AirbyteUser)-[:ADMIN_OF]->(:AirbyteOrganization)
  

AirbyteWorkspace

Provides details of a single workspace.

Field	Description
id	UUID of the workspace
name	Name of the workspace
data_residency	Localization of the data (us, eu)
firstseen	Timestamp of when a sync job first created this node
lastupdated	Timestamp of the last time the node was updated

Relationships

• Workspace belong to an Organization

  (:AirbyteOrganization)-[:RESOURCE]->(:AirbyteWorkspace)
  

• Workspace contains Source, Destination, Tag, Connection

  (:AirbyteWorkspace)-[:CONTAINS]->(
      :AirbyteSource,
      :AirbyteDestination,
      :AirbyteTag,
      :AirbyteConnection
  )
  

• User is admin of an Workspace

  (:AirbyteUser)-[:ADMIN_OF]->(:AirbyteWorkspace)
  

• User is member of an Workspace

  (:AirbyteUser)-[:MEMBER_OF]->(:AirbyteWorkspace)
  

AirbyteUser

Provides details of a single user in an organization.

Ontology Mapping: This node has the extra label UserAccount to enable cross-platform queries for user accounts across different systems (e.g., OktaUser, AWSSSOUser).

Field	Description
id	Internal Airbyte user ID
name	Name of the user
email	Email of the user
firstseen	Timestamp of when a sync job first created this node
lastupdated	Timestamp of the last time the node was updated

Relationships

• User belong to an Organization

  (:AirbyteOrganization)-[:RESOURCE]->(:AirbyteUser)
  

• User is admin of an Organization

  (:AirbyteUser)-[:ADMIN_OF]->(:AirbyteOrganization)
  

• User is admin of an Workspace

  (:AirbyteUser)-[:ADMIN_OF]->(:AirbyteWorkspace)
  

• User is member of an Workspace

  (:AirbyteUser)-[:ADMIN_OF]->(:AirbyteWorkspace)
  

AirbyteSource

Provides details of a single source.

Field	Description
id	UUID of the source
name	Name of the source
type	Type of the source (eg. postgres, s3)
config_host	Host of the source
config_port	Port of the source
config_name	Name of the source (can be database name, bucket name, container name …)
config_region	Name of the regions (can be the AWS region)
config_endpoint	Endpoint for the source
config_account	Account of the source (can be AWSAccount, AzureAccount)
firstseen	Timestamp of when a sync job first created this node
lastupdated	Timestamp of the last time the node was updated

Relationships

• Source belong to an Organization

  (:AirbyteOrganization)-[:RESOURCE]->(:AirbyteSource)
  

• Workspace contains Source

  (:AirbyteWorkspace)-[:CONTAINS]->(:AirbyteSource)
  

• Connection synchronizes data from a Source

  (:AirbyteConnection)-[:SYNC_FROM]->(:AirbyteSource)
  

AirbyteDestination

Provides details of a single destination.

Field	Description
id	UUID of the destination
name	Name of the destination
type	Type of the destination (eg. postgres, s3)
config_host	Host of the destination
config_port	Port of the destination
config_name	Name of the destination (can be database name, bucket name, container name …)
config_region	Name of the regions (can be the AWS region)
config_endpoint	Endpoint for the destination
config_account	Account of the destination (can be AWSAccount, AzureAccount)
firstseen	Timestamp of when a sync job first created this node
lastupdated	Timestamp of the last time the node was updated

Relationships

• Destination belong to an Organization

  (:AirbyteOrganization)-[:RESOURCE]->(:AirbyteDestination)
  

• Workspace contains Destination

  (:AirbyteWorkspace)-[:CONTAINS]->(:AirbyteDestination)
  

• Connection synchronizes data to a Destination

  (:AirbyteConnection)-[:SYNC_TO]->(:AirbyteDestination)
  

AirbyteTag

Provides details of a single tag.

Field	Description
id	UUID of the tag
name	Name of the tag
color	hex color of the tag
firstseen	Timestamp of when a sync job first created this node
lastupdated	Timestamp of the last time the node was updated

Relationships

• Tag belong to an Organization

  (:AirbyteOrganization)-[:RESOURCE]->(:AirbyteTag)
  

• Workspace contains Tag

  (:AirbyteWorkspace)-[:CONTAINS]->(:AirbyteTag)
  

• Connection is tagged with a Tag

  (:AirbyteConnection)-[:TAGGED]->(:AirbyteTag)
  

AirbyteConnection

Provides details of a single connection.

Field	Description
id	UUID of the connection
name	name of the connection
namespace_format
prefix	Prefix text to each stream name in the destination
status	Status of the connection
data_residency	Localization of the connection (eg. us, eu)
namespace_definition	Define the location where the data will be stored in the destination
non_breaking_schema_updates_behavior	Set how Airbyte handles syncs when it detects a non-breaking schema change in the source
firstseen	Timestamp of when a sync job first created this node
lastupdated	Timestamp of the last time the node was updated

Relationships

• Connection belong to an Organization

  (:AirbyteOrganization)-[:RESOURCE]->(:AirbyteConnection)
  

• Workspace contains Connection

  (:AirbyteWorkspace)-[:CONTAINS]->(:AirbyteConnection)
  

• Connection is tagged with a Tag

  (:AirbyteConnection)-[:TAGGED]->(:AirbyteTag)
  

• Connection synchronizes data from a Source

  (:AirbyteConnection)-[:SYNC_FROM]->(:AirbyteSource)
  

• Connection synchronizes data to a Destination

  (:AirbyteConnection)-[:SYNC_TO]->(:AirbyteDestination)
  

• Connection has Stream

  (:AirbyteConnection)-[:HAS]->(:AirbyteStream)
  

AirbyteStream

Represents a single stream of a connection.

Field	Description
id	Crafted ID for the stream (connectionUUID_streamName)
name	name of the stream
sync_mode	sync method for the stream
cursor_field	name of the column that is used as a cursor
primary_key	primary key for the stream
include_files	flag for including raw files for blob sync
selected_fields	fields to sync for the stream
mappers	custom mappers for the stream
firstseen	Timestamp of when a sync job first created this node
lastupdated	Timestamp of the last time the node was updated

Relationships

• Stream belong to an Organization

  (:AirbyteOrganization)-[:RESOURCE]->(:AirbyteStream)
  

• Connection has Stream

  (:AirbyteConnection)-[:HAS]->(:AirbyteStream)