Connector for Kx kdb+tick

The Kx kdb+tick input data source allows connection to a Kx kdb+ ticker plant on a real-time streaming basis.

Specifically, it allows Panopticon to subscribe to Kx kdb+tick through the definition of Service, Table, Symbol, or directly through Functional Subscription.

 

  1. Enter the connection details: 
    Property Description

    Host

    Kx kdb+tick host address.

    Port

    Kx kdb+tick host port. Default is 5010.

    TLS Enabled

    Ensure to check if you have started q with TLS only.

    User Id

    The user Id that will be used to connect to Kx kdb+tick.

    Password

    The password that will be used to connect to Kx kdb+tick.

    NOTE: Host, Port, User Id, and Password can be parameterized.

  2. Select either Subscription Type:
    • Service

      Enter the following properties:

      • Subscription Name (e.g., .u.sub)

        NOTE:

        Instead of entering the table and symbol to subscribe against in the Table and Symbol text boxes, you can specify the full subscription syntax in the Subscription Name text box. For example:

        .u.sub[`table;`symbol]

        To subscribe to the trade table and AAPL, AIG, and DOW symbols, enter this in the Subscription Name text box:

        .u.sub[`trade;`AAPL`AIG`DOW]

      • Table to subscribe against (e.g., trade)

        NOTE:

        • You may use just a back tick for the table name, intending to subscribe to all available tables.
        • When a table name is not entered in the Table text box, then the Symbol text box is disabled meaning it will not be used while doing subscription.
      • Symbol to subscribe against (e.g., AAPL)

        NOTE: Multiple symbols should be separated by a comma.

    • Functional Subscription

      Enter the functional subscription that needs to be issued (e.g., .u.sub[`trade;`])

  3. Click Fetch Schema to retrieve the schema of the configured subscription.

    This also populates the Id Column with the set of columns, of arbitrary type, that can be concatenated to form a unique row identifier.

  4. Click Constrain subscription to matching symbols to select the column which contains specific symbols. Otherwise, the filtering against these symbols will not take place.

    NOTE: The Constrain subscription to matching symbols only lists sym fields. Therefore, if you select a non sym type in the Id Column, it is not recommended to select the default value [Id Column] in the Constrain subscription to matching symbols drop-down list.

  5.  Activate or deactivate Initialize with historic data. If not selecyed, the data source will only be populated with streaming updates that are subscribed against. If checked, the data source is first initialized against a store of data, after which subscribed streaming updates are then applied.
  6. Enter the following information:
    • Host
    • Port
    • User Id
    • Password
    • Timeout
    • Query

    These entries can be parameterized.

  7.  Select Deferred Sync Query checkbox to allow the Kxkdb+tick data source to support synchronous and asynchronous reads. The advantage of using this option is that there is no queue on the Kx kdb+tick server side, queries are farmed out to nodes and returned to asynchronous instead.
  8. Date/Time values of output data and Date/Time inputs, where supported, are by default unchanged.

    You can opt to define the Show in Timezone and Source Timezone settings.

  9. Select the Flatten List Limit.

    This allows retrieval of the first ‘n’ items in the list and produce new columns in the output schema with a dot notation.

    For example, if there are two nested fields (BidPrices and OfferPrices) and the flatten list limit selected is five, then the output schema will be:

    BidPrices.1, BidPrices.2, BidPrices.3, BidPrices.4, BidPrices.5, OfferPrices.1, OfferPrices.2, OfferPrices.3, OfferPrices.4, OfferPrices.5

    If there are less than five items in the list, then the values will be null.

    NOTE: Currently, this feature works for the Service subscription type. Also, it only flattens numeric columns.

  10. For this section:

    Refer to Define Real-Time Settings for more information.

 

 

(c) 2013-2024 Altair Engineering Inc. All Rights Reserved.

Intellectual Property Rights Notice | Technical Support