Fetch Price
Type:
fetch_price
• Category:flow
• Tags:data
,price
Description
Fetch price document(s) from dataexchange
Parameters
Name | Type | Description | Required | Default |
---|---|---|---|---|
symbol | autocomplete | no | ||
interval | string | Interval e.g. 1h | no | |
datetime | string | Exact ISO datetime (exclusive with dateFrom/dateTo) | no | |
dateFrom | date | Start ISO datetime (inclusive) | no | |
dateTo | date | End ISO datetime (inclusive) | no | |
limit | number | Max rows when using range | no | 500 |
storeVar | string | If set, store full result into vars[name] | no | |
persist | boolean | Insert result doc into persistCollection | no | false |
persistCollection | string | Collection name for persistence | no | "workflow_data" |
Help
Overview
This worker retrieves price document(s) from the DataExchange service for a specified financial market or data source. It supports both point‑in‑time queries and ranged queries over a time interval, and can optionally store the result in a workflow variable or persist it to a collection for later use.
Worker Description
Fetch price document(s) from DataExchange for financial market/data.
Worker Help
(none)
Parameters Schema
- symbol – Autocomplete field for the market symbol (e.g.,
AAPL
,BTC-USD
). - interval – String defining the aggregation interval, such as
1h
,30m
, or1d
. - datetime – Exact ISO‑8601 timestamp to fetch a single price point. This parameter is mutually exclusive with
dateFrom
/dateTo
. - dateFrom – ISO‑8601 date/time marking the inclusive start of a range query.
- dateTo – ISO‑8601 date/time marking the inclusive end of a range query.
- limit – Maximum number of rows to return when a range is requested. Defaults to 500 if omitted.
- storeVar – Name of a workflow variable where the full result set will be stored. If left empty, the result is returned directly.
- persist – Boolean flag (default false) indicating whether the fetched document should be inserted into a persistent collection.
- persistCollection – Name of the collection used for persistence when
persist
is true. Defaults to"workflow_data"
.
Minimal Example Usage
To obtain the last 100 hourly price points for the symbol ETH-USD
between *202