otp.run#

run(query, *, symbols=None, start=utils.adaptive, end=utils.adaptive, start_time_expression=None, end_time_expression=None, timezone=utils.default, context=utils.default, username=None, alternative_username=None, password=None, batch_size=utils.default, running=False, query_properties=None, concurrency=utils.default, apply_times_daily=None, symbol_date=None, query_params=None, time_as_nsec=True, treat_byte_arrays_as_strings=True, output_matrix_per_field=False, output_structure=None, return_utc_times=None, connection=None, callback=None, svg_path=None, use_connection_pool=False, node_name=None, require_dict=False, max_expected_ticks_per_symbol=None)[source]#

Executes a query and returns its result.

Parameters

  • query (onetick.py.Source, otq.Ep, otq.Graph, otq.GraphQuery, otq.ChainQuery, str, otq.Chainlet) – Query to execute can be source, path of the query on a disk or otq graph or event processor. For running OTQ files, it represents the path (including filename) to the OTQ file to run a single query within the file. If more than one query is present, then the query to be run must be specified (that is, ‘path_to_file’/otq_file.otq::query_to_run).

  • symbols (str, list of str, list of otq.Symbol, onetick.py.Source, pd.DataFrame, optional) – Symbol(s) to run the query for passed as a string, a list of strings, a pd.DataFrame with the SYMBOL_NAME column, or as a “symbols” query which results include the SYMBOL_NAME column. The start/end times for the symbols query will taken from the params below. See symbols for more details.

  • start (datetime.datetime, onetick.py.datetime, pyomd.timeval_t, optional) – The start time of the query. If datetime.datetime was pass timezone of object is ignored by Onetick, therefore we suggest using otp.datetime objects only as an argument. onetick.py uses otp.config.default_start_time as default value, if you don’t want to specify start time, e.g. to use saved time of the query, then you should specify None value. See also timezone argument.

  • end (datetime.datetime, onetick.py.datetime, pyomd.timeval_t, optional) – The end time of the query. If datetime.datetime was pass timezone of object is ignored by Onetick, therefore we suggest using otp.datetime objects only as an argument. See also timezone argument. onetick.py uses otp.config.default_end_time as default value, if you don’t want to specify end time, e.g. to use saved time of the query, then you should specify None value.

  • start_time_expression (str, optional) – Start time onetick expression of the query. If specified, it will take precedence over start. Supported only if query is Source, Graph or Event Processor.

  • end_time_expression (str, optional) – End time onetick expression of the query. If specified, it will take precedence over end. Supported only if query is Source, Graph or Event Processor.

  • timezone (str, optional) – The timezone of start and end times, as well as of the output timestamps. It has higher priority then timezone of start and end parameters. If parameter is omitted timestamps of ticks will be formatted with the default timezone.

  • context (str (defaults to otp.config.default_context), optional) – Allows specification of different instances of OneTick tick_servers to connect to

  • username (Optional[str]) – The username to make the connection. By default the user which executed the process is used.

  • alternative_username (str) – The username used for authentication. Needs to be set only when the tick server is configured to use password-based authentication. By default, otp.config.default_auth_username is used.

  • password (str, optional) – The password used for authentication. Needs to be set only when the tick server is configured to use password-based authentication. Note: not supported and ignored on older OneTick versions. By default, otp.config.default_password is used.

  • batch_size (int) – number of symbols to run in one batch. By default, the value from otp.config.default_batch_size is used.

  • running (bool, optional) – Indicates whether a query is CEP or not. Default is False.

  • query_properties ((pyomd.QueryProperties), optional) – Query properties, such as ONE_TO_MANY_POLICY, ALLOW_GRAPH_REUSE, etc

  • concurrency (int, optional) – The maximum number of CPU cores to use to process the query. By default, the value from otp.config.default_concurrency is used.

  • apply_times_daily (bool) – Runs the query for every day in the start-end time range, using the time components of start and end times.

  • symbol_date (Optional[Union[datetime.datetime, int]]) – The symbol date used to look up symbology mapping information in the reference database, expressed as datetime object or integer of YYYYMMDD format

  • query_params (dict) – Parameters of the query.

  • time_as_nsec (bool) – Outputs timestamps up to nanoseconds granularity (defaults to False: by default we output timestamps in microseconds granularity)

  • treat_byte_arrays_as_strings (bool) – Outputs byte arrays as strings (defaults to True)

  • output_matrix_per_field (bool) – Changes output format to list of matrices per field.

  • output_structure (otp.Source.OutputStructure, optional) –

    Structure (type) of the result. Supported values are:

    • ”df” (default) - the result is returned as pandas.DataFrame or dict[symbol: pandas.Dataframe] in case of multi symbols or evals.

    • ”map” - the result is returned as SymbolNumpyResultMap.

    • ”list” - the result is returned as list.

  • return_utc_times (bool) – If True Return times in UTC timezone and in local timezone otherwise

  • connection ((pyomd.Connection)) – The connection to be used for discovering nested otq files

  • callback (onetick.py.CallbackBase) – Class with callback methods. If set, the output of the query should be controlled with callbacks and this function returns nothing.

  • svg_path –

  • use_connection_pool (bool) –

  • node_name (str, List[str], optional) – Name of the output node to select result from. If query graph has several output nodes, you can specify the name of the node to choose result from. If node_name was specified, query should be presented by path on the disk and output_structure should be “df”

  • require_dict (bool) – If set to True, result will be forced to be a dictionary even if it’s returned for a single symbol

  • max_expected_ticks_per_symbol (int) – Expected maximum number of ticks per symbol (used for performance optimizations). By default, otp.config.max_expected_ticks_per_symbol is used.

Returns

result of the query

Return type

result, list, dict, pandas.DataFrame, None

Examples

Running onetick.py.Source and setting start and end times

>>> data = otp.Tick(A=1)
>>> otp.run(data, start=otp.dt(2003, 12, 2), end=otp.dt(2003, 12, 4))
        Time  A
0 2003-12-02  1

Running otq.Ep and passing query parameters

>>> ep = otq.TickGenerator(bucket_interval=0, fields='long A = $X').tick_type('TT')
>>> otp.run(ep, symbols='LOCAL::', query_params={'X': 1})
        Time  A
0 2003-12-04  1

Running in callback mode

>>> class Callback(otp.CallbackBase):
...     def __init__(self):
...         self.result = None
...     def process_tick(self, tick, time):
...         self.result = tick
>>> data = otp.Tick(A=1)
>>> callback = Callback()
>>> otp.run(data, callback=callback)
>>> callback.result
{'A': 1}