CopyBlobFromCrest Namespace Reference

Functions
def	fetch_calib_data (server, tag, run, lumi, channels)
def	process_channel_list (channel_list)
def	output_filename (args)
def	save_calib_data_to_file (blobs, output_file, requested_channels=None)
def	setup_argparser ()

Variables
	log
	logLevel
	log1
	schema
	args
	payload_data
	server
	tag
	run
	lumi
	channels
	ofile

Function Documentation

fetch_calib_data()

def CopyBlobFromCrest.fetch_calib_data	(		server,
			tag,
			run,
			lumi,
			channels
	)

Fetch calibration data from TileBlobReaderCrest.

Args:
    server (str): CREST server URL.
    tag (str): Tag identifying the calibration data.
    run (int): Run number to fetch data for.
    lumi (int): Lumi block to fetch data for.
    channels (list of int): List of COOL channel numbers.

Returns:
    list: List of calibration data entries retrieved.

Definition at line 68 of file CopyBlobFromCrest.py.

def fetch_calib_data(server, tag, run, lumi, channels):
    """
    Fetch calibration data from TileBlobReaderCrest.
 
    Args:
        server (str): CREST server URL.
        tag (str): Tag identifying the calibration data.
        run (int): Run number to fetch data for.
        lumi (int): Lumi block to fetch data for.
        channels (list of int): List of COOL channel numbers.
 
    Returns:
        list: List of calibration data entries retrieved.
    """
    try:
        log.info("Initializing TileBlobReaderCrest...")
        folderTag = tag
        if folderTag.startswith("Tile") or folderTag.startswith("CALO"):
           folderPath = ""
 
        # Create the TileBlobReaderCrest object and pass the relevant arguments
        blob_reader = TileCalibCrest.TileBlobReaderCrest(schema, folderPath, tag, run, lumi,copyBlob=True)
        # blob_reader = TileCalibCrest.TileBlobReaderCrest(server, tag, run, lumi, min(channels), max(channels))
 
 
        blobs = blob_reader.payload  # Retrieve the calibration data
        log.info(f"Successfully fetched {len(blobs)} calibration entries.")
        return blobs
 
    except Exception as e:
        log.error(f"Error while retrieving calibration data: {e}")
        raise
 

output_filename()

def CopyBlobFromCrest.output_filename

(

args

)

Definition at line 121 of file CopyBlobFromCrest.py.

def output_filename(args):
    if not args.output:
        # Format run and lumi as strings to ensure they're properly handled
        run_str = str(args.run)
        lumi_str = str(args.lumi)
 
        # Construct filename from components
        tag = args.tag if args.tag else "default"
 
        # Add channel numbers in name if they were defined in args
        if hasattr(args, 'channel') and args.channel:
            # Process the channel list using the utility function
            processed_channels = args.channel[0].split(',')
            channel_str = '-'.join(processed_channels)
            return f"{tag}.{run_str}.{lumi_str}.ch{channel_str}.json"
        else:
            # Return filename without channel information if default value is used
            return f"{tag}.{run_str}.{lumi_str}.json"
 
    return args.output
 

process_channel_list()

def CopyBlobFromCrest.process_channel_list

(

channel_list

)

Process a list of channel identifiers, handling comma-separated values.

Args: channel_list (list): List of channel identifiers, which may contain comma-separated value
Returns: list: Processed list of individual channel identifiers

Definition at line 101 of file CopyBlobFromCrest.py.

def process_channel_list(channel_list):
    """
    Process a list of channel identifiers, handling comma-separated values.
 
    Args: channel_list (list): List of channel identifiers, which may contain comma-separated value
    Returns: list: Processed list of individual channel identifiers
    """
    processed_channels = []
    if channel_list:
        for item in channel_list:
            # If an item contains commas, split it and add each part
            if isinstance(item, str) and ',' in item:
                parts = [part.strip() for part in item.split(',')]
                processed_channels.extend(parts)
            else:
                processed_channels.append(str(item))
 
    return processed_channels
 
 

save_calib_data_to_file()

def CopyBlobFromCrest.save_calib_data_to_file	(		blobs,
			output_file,
			requested_channels = None
	)

Save fetched calibration data to a file.
Parameters:
-----------
blobs : dict containing calibration data blobs
output_file : str Path to the output file where data will be saved
requested_channels : list, optional
    List of specific channels to include in the output file.
    If None, all channels from the blobs will be included.

Definition at line 142 of file CopyBlobFromCrest.py.

def save_calib_data_to_file(blobs, output_file, requested_channels=None):
    """
    Save fetched calibration data to a file.
    Parameters:
    -----------
    blobs : dict containing calibration data blobs
    output_file : str Path to the output file where data will be saved
    requested_channels : list, optional
        List of specific channels to include in the output file.
        If None, all channels from the blobs will be included.
    """
    try:
        log.info(f"Saving calibration data to {output_file}")
 
        if requested_channels is not None:
            # Process the channel list using the utility function
            processed_channels = set(process_channel_list(requested_channels))
 
            # Filter blobs to only include requested channels
            filtered_blobs = {channel: data for channel, data in blobs.items()
                              if channel in processed_channels}
 
            blobs_to_save = filtered_blobs
        else:
            # Save all blobs if no channel filtering is requested
            blobs_to_save = blobs
 
        with open(output_file, "w") as f:
            json.dump(blobs_to_save, f)
 
        log.info("Calibration data successfully written to output file.")
 
    except Exception as e:
        log.error(f"Error while saving calibration data: {e}")
        raise

setup_argparser()

def CopyBlobFromCrest.setup_argparser

(

)

Set up command-line argument parser.

Returns:
    argparse.ArgumentParser: Configured argument parser

Definition at line 177 of file CopyBlobFromCrest.py.

def setup_argparser():
    """
    Set up command-line argument parser.
 
    Returns:
        argparse.ArgumentParser: Configured argument parser
    """
    parser = argparse.ArgumentParser(description="Read TileCal blobs from CREST and convert them to JSON format.")
 
    parser = argparse.ArgumentParser(description="Read TileCal blobs from CREST and convert them to JSON format.")
    parser.add_argument(
        "-s", "--server",
        default="http://crest-j23.cern.ch:8080/api-v5.0",
        help="Specify CREST server URL (default is %(default)s)."
    )
 
    parser.add_argument(
        "-t", "--tag",
        default='TileOfl02CalibCes-RUN2-UPD4-29',
        help="Specify the tag to use (e.g., RUN2-UPD4-04). Default is %(default)s."
    )
    parser.add_argument(
        "-r", "--run",
        type=int,
        default=2147483647,  # Largest IOV value (default for latest run)
        help="Specify the run number (default is the latest IOV, %(default)s)."
    )
    parser.add_argument(
        "-l", "--lumi",
        type=int,
        default=0,
        help="Specify the lumi block number (default is %(default)s)."
    )
    parser.add_argument(
        "-c", "--channel",
        type=str,  # Changed to str to accept comma values
        nargs="+",
        help="Specify COOL channels (default includes all channels from 0-275 and 1000). Use space or comma-separated values."
    )
 
    parser.add_argument(
        "-o", "--output",
        default=None,
        help="Specify the output JSON file for saving calibration data. If not provided, will use '[tag].[run].[lumi].json'"
    )
 
    # Parse arguments from the command line
    args = parser.parse_args()
 
    return args
 

Variable Documentation

args

CopyBlobFromCrest.args

Definition at line 230 of file CopyBlobFromCrest.py.

channels

CopyBlobFromCrest.channels

Definition at line 240 of file CopyBlobFromCrest.py.

log

CopyBlobFromCrest.log

Definition at line 60 of file CopyBlobFromCrest.py.

log1

CopyBlobFromCrest.log1

Definition at line 64 of file CopyBlobFromCrest.py.

logLevel

CopyBlobFromCrest.logLevel

Definition at line 61 of file CopyBlobFromCrest.py.

lumi

CopyBlobFromCrest.lumi

Definition at line 239 of file CopyBlobFromCrest.py.

ofile

CopyBlobFromCrest.ofile

Definition at line 244 of file CopyBlobFromCrest.py.

payload_data

CopyBlobFromCrest.payload_data

Definition at line 235 of file CopyBlobFromCrest.py.

run

CopyBlobFromCrest.run

Definition at line 238 of file CopyBlobFromCrest.py.

schema

CopyBlobFromCrest.schema

Definition at line 66 of file CopyBlobFromCrest.py.

server

CopyBlobFromCrest.server

Definition at line 236 of file CopyBlobFromCrest.py.

tag

CopyBlobFromCrest.tag

Definition at line 237 of file CopyBlobFromCrest.py.