atomiq.components.basics.datasink

Classes

DataSink	Represent an abstract data sink and define methods it must provide.
RPCPublisherSink	Represent an abstract data sink and define methods it must provide.
HEROSink	Represent an abstract data sink and define methods it must provide.
DatabaseSink	Represent an abstract data sink and define methods it must provide.
ARTIQDatasetSink	Represent an abstract data sink and define methods it must provide.

Module Contents

class atomiq.components.basics.datasink.DataSink(*args, **kwargs)

Bases: atomiq.components.primitives.Component

Represent an abstract data sink and define methods it must provide.

submit_env(point, identifier=None, *args, **kwargs)

abstractmethod submit_data(field_names, values, identifier=None, *args, **kwargs)

Parameters:

• field_names (artiq.language.types.TList)

• values (artiq.language.types.TList)

experiment

identifier

debug_output = False

core

_kernel_invariants

_prepare_done = False

_build_done = False

_hooks_done = []

children = []

__in_build = True

class atomiq.components.basics.datasink.RPCPublisherSink(rpc_publisher, topic_prefix='', default_topic='newData', *args, **kwargs)

Bases: DataSink

Represent an abstract data sink and define methods it must provide.

Parameters:

• rpc_publisher (Component)

• topic_prefix (artiq.language.types.TStr)

• default_topic (artiq.language.types.TStr)

kernel_invariants

rpc_publisher

default_topic = 'newData'

topic_prefix = ''

submit_env(point, identifier=None, *args, **kwargs)

submit_data(field_names, values, identifier=None, topic=None)

Parameters:

• field_names (artiq.language.types.TList)

• values (artiq.language.types.TList)

experiment

identifier

debug_output = False

core

_kernel_invariants

_prepare_done = False

_build_done = False

_hooks_done = []

children = []

__in_build = True

class atomiq.components.basics.datasink.HEROSink(*args, **kwargs)

Bases: DataSink

Represent an abstract data sink and define methods it must provide.

submit_env(point, identifier=None, *args, **kwargs)

submit_data(field_names, values, identifier=None)

Parameters:

• field_names (artiq.language.types.TList)

• values (artiq.language.types.TList)

experiment

identifier

debug_output = False

core

_kernel_invariants

_prepare_done = False

_build_done = False

_hooks_done = []

children = []

__in_build = True

class atomiq.components.basics.datasink.DatabaseSink(*args, **kwargs)

Bases: DataSink

Represent an abstract data sink and define methods it must provide.

submit_env(point, identifier=None, *args, **kwargs)

abstractmethod submit_data(field_names, values, identifier=None, *args, **kwargs)

Parameters:

• field_names (artiq.language.types.TList)

• values (artiq.language.types.TList)

experiment

identifier

debug_output = False

core

_kernel_invariants

_prepare_done = False

_build_done = False

_hooks_done = []

children = []

__in_build = True

class atomiq.components.basics.datasink.ARTIQDatasetSink(*args, **kwargs)

Bases: DataSink

Represent an abstract data sink and define methods it must provide.

submit_env(point, identifier=None, *args, **kwargs)

abstractmethod submit_data(field_names, values, identifier=None, *args, **kwargs)

Parameters:

• field_names (artiq.language.types.TList)

• values (artiq.language.types.TList)

experiment

identifier

debug_output = False

core

_kernel_invariants

_prepare_done = False

_build_done = False

_hooks_done = []

children = []

__in_build = True