amstrax package
Subpackages
- amstrax.auto_processing package
- amstrax.plugins package
- Submodules
- amstrax.plugins.daqreader module
DAQReader
DAQReader.chunk_target_size_mb
DAQReader.compressor
DAQReader.compute()
DAQReader.data_kind
DAQReader.depends_on
DAQReader.infer_dtype()
DAQReader.input_timeout
DAQReader.is_ready()
DAQReader.parallel
DAQReader.provides
DAQReader.rechunk_on_save
DAQReader.setup()
DAQReader.source_finished()
DAQReader.takes_config
split_channel_ranges()
- amstrax.plugins.event_processing module
- amstrax.plugins.pax_interface module
- amstrax.plugins.peak_processing module
- amstrax.plugins.pulse_processing module
PulseProcessing
PulseProcessing.compressor
PulseProcessing.compute()
PulseProcessing.config
PulseProcessing.data_kind
PulseProcessing.depends_on
PulseProcessing.deps
PulseProcessing.dtype
PulseProcessing.infer_dtype()
PulseProcessing.input_buffer
PulseProcessing.parallel
PulseProcessing.provides
PulseProcessing.rechunk_on_save
PulseProcessing.run_i
PulseProcessing.run_id
PulseProcessing.takes_config
baseline_per_channel()
channel_split()
check_overlaps()
mask_and_not()
pulse_count_dtype()
- amstrax.plugins.pulse_processing_alt_baseline module
- Module contents
Submodules
amstrax.SiPMdata module
amstrax.common module
- amstrax.common.print_versions(modules=('strax', 'amstrax'), print_output=True, include_python=True, return_string=False, include_git=True)[source]
Print versions of modules installed. :param modules: Modules to print, should be str, tuple or list. E.g.
print_versions(modules=(‘numpy’, ‘dddm’,))
- Parameters
return_string – optional. Instead of printing the message, return a string
include_git – Include the current branch and latest commit hash
- Returns
optional, the message that would have been printed
amstrax.contexts module
- amstrax.contexts.context_for_daq_reader(st: Context, run_id: str, detector: str = 'xams', runs_col_kwargs: Optional[dict] = None, run_doc: Optional[dict] = None, check_exists=True)[source]
Given a context and run_id, change the options such that we can process the live data.
IMPORTANT: After setting the context, we specify the location of the live-data for a single run. This means you CANNOT re-use this context! Therefore, if you want to process data, you should start a new context if you want to process another run starting from the live data
- Parameters
st – Context to change
run_id – the run_id of the run that should be processed
runs_col_kwargs – Optional options (kwargs) for starting the run-collection, see get_mongo_collection
run_doc – Optional document associated with this run-id.
- Returns
Context ready to start processing <run_id> with from the live-data
amstrax.hitfinder_thresholds module
- amstrax.hitfinder_thresholds.hit_min_amplitude(model, n_tpc_pmts=16)[source]
Return hitfinder height threshold to use in processing.
- Parameters
model – Model name (str), or int to use a uniform threshold,
or array/tuple or thresholds to use. :param threshold: value of the threshold to be applied in ADC counts.
amstrax.itp_map module
amstrax.rundb module
- class amstrax.rundb.RunDB(mongo_dbname='admin', mongo_collname='runs_gas', runid_field='name', local_only=True, new_data_path=None, reader_ini_name_is_mode=False, readonly=True, *args, **kwargs)[source]
Bases:
StorageFrontend
Frontend that searches RunDB MongoDB for data.
Loads appropriate backends ranging from Files to S3.
- find_several(keys: List[DataKey], **kwargs)[source]
Return list with backend keys or False for several data keys.
Options are as for find()
- hosts = {'dali': '^dali.*rcc.*'}
- provide_run_metadata = True