forked from episodes-platform/shared-snippets
Compare commits
8 Commits
d0bffa2aad
...
feature/IS
Author | SHA1 | Date | |
---|---|---|---|
d9a962e3bb | |||
9770709a81 | |||
9fa094a2dc | |||
60e52884f4 | |||
e8ed57e2a0 | |||
1fa3edf796 | |||
d4a248df3b | |||
7ba8869df0 |
@@ -65,7 +65,7 @@ classdef base_logger < handle
|
||||
function this = base_logger()
|
||||
logFileName = getenv("APP_LOG_FILE");
|
||||
if isempty(logFileName)
|
||||
logFileName = 'fallbackPathApplication.log';
|
||||
logFileName = 'base-logger-log.log';
|
||||
end
|
||||
this.fid = fopen(logFileName, 'a');
|
||||
if this.fid == -1
|
||||
|
@@ -65,7 +65,7 @@ classdef base_logger < handle
|
||||
function this = base_logger()
|
||||
logFileName = getenv("APP_LOG_FILE");
|
||||
if isempty(logFileName)
|
||||
logFileName = 'fallbackPathApplication.log';
|
||||
logFileName = 'base-logger-log.log';
|
||||
end
|
||||
this.fid = fopen(logFileName, 'a');
|
||||
if this.fid == -1
|
||||
|
36
python/catalog/find_catalog_column.py
Normal file
36
python/catalog/find_catalog_column.py
Normal file
@@ -0,0 +1,36 @@
|
||||
# -----------------
|
||||
# Copyright © 2024 ACK Cyfronet AGH, Poland.
|
||||
#
|
||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
||||
# you may not use this file except in compliance with the License.
|
||||
# You may obtain a copy of the License at
|
||||
#
|
||||
# http://www.apache.org/licenses/LICENSE-2.0
|
||||
#
|
||||
# Unless required by applicable law or agreed to in writing, software
|
||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
# See the License for the specific language governing permissions and
|
||||
# limitations under the License.
|
||||
#
|
||||
# This work was partially funded by DT-GEO Project.
|
||||
# -----------------
|
||||
def find_catalog_column(catalog, field_name):
|
||||
"""
|
||||
Finds the index of a column in the catalog based on its field name.
|
||||
|
||||
Parameters:
|
||||
catalog (np.ndarray): A structured NumPy array representing a catalog in EPISODES Platform format:
|
||||
https://docs.cyfronet.pl/display/ISDOC/Catalogs
|
||||
field_name (str): The field name of the entry to search for.
|
||||
|
||||
Returns:
|
||||
int: The index of the entry matching the given field name.
|
||||
|
||||
Raises:
|
||||
ValueError: If the specified field name is not found in the catalog.
|
||||
"""
|
||||
for idx, col in enumerate(catalog):
|
||||
if col['field'] == field_name:
|
||||
return idx
|
||||
raise ValueError(f'No {field_name} field found in the catalog.')
|
44
python/catalog/sort_by_time.py
Normal file
44
python/catalog/sort_by_time.py
Normal file
@@ -0,0 +1,44 @@
|
||||
# -----------------
|
||||
# Copyright © 2024 ACK Cyfronet AGH, Poland.
|
||||
#
|
||||
# Licensed under the Apache License, Version 2.0 (the "License");
|
||||
# you may not use this file except in compliance with the License.
|
||||
# You may obtain a copy of the License at
|
||||
#
|
||||
# http://www.apache.org/licenses/LICENSE-2.0
|
||||
#
|
||||
# Unless required by applicable law or agreed to in writing, software
|
||||
# distributed under the License is distributed on an "AS IS" BASIS,
|
||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
# See the License for the specific language governing permissions and
|
||||
# limitations under the License.
|
||||
#
|
||||
# This work was partially funded by DT-GEO Project.
|
||||
# -----------------
|
||||
import numpy as np
|
||||
from find_catalog_column import find_catalog_column
|
||||
|
||||
def sort_by_time(catalog):
|
||||
"""
|
||||
Sorts the given catalog based on the 'Time' column. Requires find_catalog_column script to work.
|
||||
|
||||
Parameters:
|
||||
catalog (np.ndarray): A structured NumPy array representing a seismic catalog in EPISODES Platform format:
|
||||
https://docs.cyfronet.pl/display/ISDOC/Seismic+catalog
|
||||
|
||||
Returns:
|
||||
np.ndarray: The sorted catalog, where rows in 'val' fields are ordered by ascending 'Time' values.
|
||||
|
||||
Raises:
|
||||
ValueError: If the 'Time' column is not found in the catalog.
|
||||
"""
|
||||
time_col_index = find_catalog_column(catalog, 'Time')
|
||||
|
||||
time_values = catalog[time_col_index]['val'].flatten()
|
||||
sorted_indexes = np.argsort(time_values)
|
||||
|
||||
sorted_catalog = catalog.copy()
|
||||
for field in sorted_catalog:
|
||||
field['val'] = field['val'][sorted_indexes]
|
||||
|
||||
return sorted_catalog
|
@@ -12,7 +12,7 @@ def getDefaultLogger(name):
|
||||
|
||||
The logger is configured to write log messages to the file path specified by the
|
||||
'APP_LOG_FILE' environment variable. If the environment variable is not set,
|
||||
the logger will write to the file 'fallbackPathApplication.log' in the current
|
||||
the logger will write to the file 'base-logger-log.log' in the current
|
||||
working directory. The logger uses the 'INFO' level as the default logging level
|
||||
and writes log entries in the following format:
|
||||
|
||||
@@ -33,7 +33,7 @@ def getDefaultLogger(name):
|
||||
logger : logging.Logger
|
||||
A logger instance with the specified name. The logger is configured with a
|
||||
file handler that writes to the file specified by the 'APP_LOG_FILE'
|
||||
environment variable, or to 'fallbackPathApplication.log' if the environment
|
||||
environment variable, or to 'base-logger-log.log' if the environment
|
||||
variable is not set.
|
||||
|
||||
Example:
|
||||
@@ -48,12 +48,12 @@ def getDefaultLogger(name):
|
||||
Notes:
|
||||
------
|
||||
- The 'APP_LOG_FILE' environment variable should specify the full path to the log file.
|
||||
- If 'APP_LOG_FILE' is not set, logs will be written to 'fallbackPathApplication.log'.
|
||||
- If 'APP_LOG_FILE' is not set, logs will be written to 'base-logger-log.log'.
|
||||
|
||||
"""
|
||||
logger = logging.getLogger(name)
|
||||
if not logger.hasHandlers():
|
||||
file_handler = logging.FileHandler(os.environ.get('APP_LOG_FILE', 'fallbackPathApplication.log'), mode='a')
|
||||
file_handler = logging.FileHandler(os.environ.get('APP_LOG_FILE', 'base-logger-log.log'), mode='a')
|
||||
formatter = logging.Formatter('%(asctime)s,%(msecs)d %(levelname)s %(name)s %(message)s')
|
||||
file_handler.setFormatter(formatter)
|
||||
logger.addHandler(file_handler)
|
||||
|
Reference in New Issue
Block a user