Tool for parsing matrix files, extracting actions and processing them according to user defined logic
Project description
run-one
Tool for parsing matrix files, extracting actions and processing them according to user defined logic
How to setup environment and install dependencies
python -m venv $VENV_PATH
$VENV_PATH/bin/pip install -U pip setuptools
$VENV_PATH/bin/pip install poetry
$VENV_PATH/bin/poetry install -E th2
Note: -E th2
is optional and can be omitted if you don't need th2-related dependencies.
Config example (using th2 processor)
matrix_path: "matrix_case.csv" # path to matrix file or directory with matrices
filename_pattern: "*.matrix.csv" # matching pattern for files (can contain shell-style wildcards)
processed_actions: # which actions to process (action name to name of handler class)
send: "TH2ActHandler"
receive: "TH2Check1Handler"
store: "TH2EstoreHandler"
sleep: "SleepHandler"
actSsh: "TH2ActSSHHandler"
field_mapping: # mapping for field renaming (old name to new name)
TIF: "TimeInForce"
nested_fields: ["NoPartyIDs", "OrderQtyData", "Parties", "Instrument"] # which fields to convert to collections
fields_to_drop: # which fields to remove
["PreviousID", "Protocol", "CaseName", "Seq"]
fields_to_extract: # which fields to extract and keep as additional information
["Action", "MessageType", "Time", "User", "ID", "ExecutionAlias", "Direction", "Description"]
regenerate_id_fields: ["ClOrdID", "OrigClOrdID"] # ID-like fields to regenerate
regenerate_time_fields: ["TransactTime"] # Time-like fields to regenerate
processor_config: # processor config in free form
th2_configs: "th2_configs" # path to directory with th2 configs
root_event_name: 'run-one root event' # name of created root event
book: "test_book" # book name
scope: "test_script" # scope name
use_place_method: False # use th2 act place methods (True) or plain send (False)
key_fields: # mapping of key fields (message type to list of field names with support of nested fields) for th2-check1 request
ExecutionReport:
- "Side"
- "ClOrdID"
- "OrigClOrdID"
- Instrument:
- "Symbol"
fail_unexpected: "NO" # rule of failing the validation for th2-check1 request if any unexpected field received
ignore_fields: # mapping of fields (message type to list of field names) to be ignored in the th2-check1 rule validation
ExecutionReport:
- "header"
- "trailer"
sleep: 1 # delay between each action processing in seconds
matrix_delay: 5 # delay between each matrix processing in seconds
timestamp_shift: 1 # for how many seconds to the past make a shift for event timestamps
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for run_one-1.2.9.dev10366284869.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 191756d501c34e3d082df88928f8cabc282fb5927569af161df31be8b8ac0967 |
|
MD5 | 5220dbfc22c1c3b8a9ad362993beab12 |
|
BLAKE2b-256 | 4ffe17c82ed49a977adefeec13becb306170deba68d9757668a9fba83e476492 |
Close
Hashes for run_one-1.2.9.dev10366284869-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 5bb0782ce08f663585d07454881ad85e4a8a0234c8106e9a659fa1e7803763f3 |
|
MD5 | 669871c111d7993678a968ff72f95c2c |
|
BLAKE2b-256 | 0dea691e5554abe1b09ff5660775d5fc0229fb8f4f3f05551cff7256e0efd5e7 |