Commands encoded via streaming-data-types are used to start and stop file writing.
All commands are sent through Kafka via the broker and topic specified by the
--command-status-uri option.
Start commands can also be sent via the topic specified by
--job-pool-uri, where a pool of file-writers can be
configured to consume jobs from a common topic.
When a pool is used, the start command typically specifies
a separate topic (in the control_topic field) that will be used for further communication related to the job.
There are 5 types of messages:
- pl72 (run start): Command to start file-writing.
- 6s4t (run stop): Command to set the stop time of file-writing (optional, the "run start" message can already contain a stop time).
- anws (command answer): Reply to start/stop commands (the command can be accepted or rejected).
- x5f2 (status): Periodic status reports sent by the file-writer.
- wrdn (finished writing): Reports the completion of a file-writing job (the job may have succeeded or failed).
If a control_topic is specified in the RunStart message, the file-writer will, after consuming the RunStart message,
switch all subsequent communications regarding the writing job to that topic.
This means that the command answer, status and finished writing
messages will be sent to the topic indicated in the RunStart message.
After completing the job, the file-writer will switch back to its
default command and pool topics.
The nexus_structure represents the HDF root object of the file to be written.
For more detailed information on all aspects of HDF5 see the official HDF5 documentation.
For more information about NeXus see the NeXus website.
Groups are the container mechanism by which HDF5 files are organised; they can be thought of as analogous to directories in a file system. In the file-writer, they can contain datasets, streams, links or, even, other groups in their array of children. They can also have attributes defined which are used to provide metadata about the group; see below for more information on attributes.
NeXus classes are defined using a group with an attribute named NX_class which contains the relevant class name.
Other NeXus-related information can also defined using attributes. See the NeXus website for more information.
The following shows a simple example of a structure of nested groups:
"nexus_structure": {
"children": [
{
"type": "group",
"name": "my_test_group",
"children": [
{
"type": "group",
"name": "my_nested_group_1"
},
{
"type": "group",
"name": "my_nested_group_2",
"attributes": [
{
"NX_class": "NXlog",
"unit": "blintz"
}
]
}
],
"attributes": [
{
"NX_class": "NXentry",
"origin": "spaaaaace"
}
]
}
]
}In the above example, the attributes are assigned to the groups that are defined on the same level.
The (stream/writer) module definition instructs the file-writer that there is data available which should be written to the containing group. The example below illustrates how this can be done.
"nexus_structure": {
"children": [
{
"type": "group",
"name": "my_test_group",
"children": [
{
"module": "f142",
"config": {
"dtype": "double",
"source": "my_test_pv",
"topic": "my_test_topic"
}
}
]
}
]
}In the example above, a group called my_test_group is defined which in turn has a (stream) writer module and an attribute defined.
The parameters for the stream/module definition are:
- module: The either the file identifier of a FlatBuffers schema in the streaming-data-types repository that was used to serialise the data or another identifier if there exists multiple writer modules for the same schema.
- dtype: The type of the data. The possible types are defined in the schema declared in the
writer_module. Note that not all the writer modules take this parameter. - source: The name of the data source. For example, the EPICS PV name.
- topic: The Kafka topic where the data can be found.
Note also that some module specific parameters exists. You can find the documentation on individual writer modules in this directory.
A NX_class value will be assigned to the group containing the dataset automatically.
Attributes should not be assigned at the "group" level. The file-writer module owns the group and any attributes must be created from inside module. The module's arguments can be used to pass any
information that needs to be written as an attribute.
Static datasets use the same general structure as writer-modules.
"nexus_structure": {
"children": [
{
"module": "dataset",
"config": {
"name": "some_static_data",
"dtype": "int64",
"values": [
[0, 1, 3 ],
[2, 2, 1 ]
]
},
"attributes": {
"NX_class": "NXlog"
}
}
]
}In the above example, a dataset is defined which contains some values in two dimenstional array.
The parameters for the dataset definition are:
- name: The name of the dataset in the NeXus file.
- values: The data to be stored in the dataset. Note that the shape of the dataset is determined from the layout of the data in the JSON structure.
- dtype: The data type of the individual elements in the dataset. Defaults to double.
In this example, attributes are assigned to the dataset on the same level in the hierarchy.
In HDF5 links are used to link a group to objects in other groups in a manner similar to links on a filesystem.
The links are created as hard links when the file is closed. A link is defined in the children of a group.
For example:
"nexus_structure": {
"children": [
{
"type": "group",
"name": "group_with_a_link",
"children": [
{
"module": "link",
"config": {
"name": "some_link_to_value",
"source": "../group_with_dataset/some_static_data/values"
}
},
]
},
{
"type": "group",
"name": "group_with_dataset",
"children": [
{
"module": "dataset",
"config": {
"name": "some_static_data",
"dtype": "int64",
"values": [ 0, 1, 3, 2, 2 ]
},
"attributes": {
"NX_class": "NXlog"
}
}
]
}
]
}The file-writer can use HDF5's Single Writer Multiple Reader feature (SWMR) which is enable by default.
To read and write HDF files which use the SWMR feature requires HDF5 version 1.10 or higher.
One can also use the HDF5 tool h5repack with the --high option to convert the file into a HDF5 1.8 compatible version. Please refer to see the h5repack documentation for more information.
Please note, the HDF documentation warns that:
"The HDF5 file that is accessed by SWMR HDF5 applications must be located on a
file system that complies with the POSIX write() semantics."
Also:
"The writer is not allowed to modify or append to any data items containing variable-size datatypes (including string and region references datatypes)."
Attributes are used to define metadata about the data object. NeXus also uses them to define NeXus classes for groups.
Simple attributes are defined as key-value pairs, for example:
"attributes": {
"units": "Kelvin",
"error": 0.02
}Where possible the file-writer will try to infer the type of the data, in this example: a float.
For strings and arrays it is necessary to specify additional supporting information, thus these attributes are defined using a dictionary of key-value pairs.
Both strings and arrays need a type to be defined. Strings also require the string_size and, optionally, encoding to be defined. If no encoding is defined then UTF-8 is assumed.
For example:
"attributes": [
{
"name": "some_string_attribute",
"values": "some_string_value",
"dtype": "string",
},
{
"name": "array_attribute",
"values": [1, 2, 3],
"dtype": "uint32"
}
]Note: The two methods for defining attributes (key-value pairs and dictionaries) can not be mixed in the same set of attributes.