Live Drilling
  • Introduction
  • FAQ
  • what's new
    • Latest releases
      • Wells 5
      • LiveRig 5
      • LiveRig 4
      • WITSML Store
    • Operations in Time by Depth Chart
    • Unit Sets
      • Per-Asset Units
      • Unit Conversion
      • Dashboard Configuration
      • Force Follow Asset Units
    • Well casing shoe schematic
    • Wells correlation
    • FFT spectrum
    • Pressure Tests
      • Configuration
      • Automated Standard Pressure Tests
      • Manual Pressure Test
      • LOT/FIT
    • Rig State detection
    • BOP Schematic
      • BOP status register
    • Signal Processing
      • Moving Average
  • Data Flow
    • Introduction
    • Data Ingestion
    • Data Normalization
      • Clock Synchronization
      • Normalized events schema
      • Data indexes and enrichment
      • Unit conversion
      • Auto-Switch
  • Physical Models
    • Introduction
      • Structure of the functions
      • Validation
    • General Equations
      • Static Data Dependencies
      • Pipes Functions
    • Trajectory
      • Introduction
      • Static Data Dependencies
      • Pipes Functions
    • Hydraulic
      • Introduction
      • Static Data Dependencies
      • Pipes Functions
    • Torque and Drag
      • Introduction
      • Static Data Dependencies
      • Pipes Functions
    • Hole Cleaning
      • Introduction
      • Static Data Dependencies
      • Pipes Functions
    • Surge and Swab
      • Introduction
      • Static Data Dependencies
      • Pipes Functions
    • Thermal
      • Introduction
    • Volume Tracker
      • Introduction
      • Pipes Functions
  • Basic Features
    • Charts
      • Channels Charts
        • Temporal Channels Chart
        • Channel Value Chart
        • Depth Channels Chart
        • Data navigation
          • Span Control
      • Rig Allocation Gantt Chart
    • Unit sets
      • Configuration changes on unit sets
      • Depth unit changes
      • Personal units sets
    • Permission schema
    • Import/Export Well
    • Add-ons
  • Static Data
    • Assets
      • Assets Structure
    • Well
      • Introduction
      • Well Schema
      • Well Units
      • Regions, fields and countries
      • Well Design Overview
      • Objectives
    • Intervention
      • Introduction
      • Intervention Schema
      • Intervention Types
      • Scenarios
      • Runs
      • Completion and Abandonment
      • Drilling Section Schema
    • Rig
      • Introduction
      • Rig Schema
      • Physical models configuration
    • Pipes functions
    • REST API Examples
  • Administration
    • High Frequency Data
      • WITSML Null Values
      • Unit Management Tools
      • WITS Custom Mapping
    • Data Normalization
      • Data Management
        • Event Settings
        • Channels Management
      • Data normalization templates
      • Data normalization templates prioritization
      • Auto-Switch
    • Standard Identifiers
    • Static Data
      • Regions, fields and countries
      • Intervention Types
  • LiveRig Collector
    • Introduction
    • Getting Started
    • Connecting to Intelie Live
    • Security
    • Local data storage
    • Data transmission and recovery
    • Monitoring
    • Remote Control
      • APIs
        • /testSourceEndpoint
        • /storeConfiguration
        • /getFromStore
        • /backlog-sync
      • Sources
        • MQTT Topics
        • OPC Requests
        • WITSML Backlog Sync
        • WITSML Object Explorer
        • WITSML Requests
      • Properties
    • HA Deployment
    • Protocols
      • WITSML
      • WITS
      • OPC-DA
      • OPC-UA
      • MODBUS
      • MQTT
      • CSV
      • RAW
    • Protocol conversion
    • Configuration
      • liverig.properties
      • sources.xml
      • store.json
      • modbus.json
      • mqtt.json
      • Configuring an OPC-UA source
      • Multiple event types for WITSML sources
      • Certificate-based authentication for WITSML HTTPS sources
    • LiveRig Collector Appliance
    • Command line Interface (CLI)
  • LIVE EDGE
    • Collector Reader
  • Integrations
    • Introduction
    • WITSML Store
    • REST Output
    • REST Input
    • WellView
    • OpenWells
    • Python
  • DEVELOPER
    • Identified Curves
    • Hidden Units
  • DEPRECATED
    • WITSML Output
    • LiveRig 3.x / 2.x
      • 3.5.0
      • 3.4.0
      • 3.3.0
      • 3.2.0
      • 3.1.0
      • 3.0.0
      • 2.29.0
Powered by GitBook
On this page
  • Edge architectures overview
  • Installation
  • Configuration
  • Receiving events

Was this helpful?

  1. LIVE EDGE

Collector Reader

Live provides collector reader plugin to collect and ingest data between a cloud and edge instance

PreviousCommand line Interface (CLI)NextIntroduction

Last updated 2 years ago

Was this helpful?

Edge architectures overview

Live plugin to read data being ingested by a LiveRig Collector at the same machine, or at least in the same filesystem. LiveRig Collector data.log files will be monitored, parsed and will create local events to represent the same information. This plugin enables the installation of an additional Live instance at the Edge environments to use the events locally without any impact on the ordinary LiveRig Collector data flow tasks for the central site.

This plugin must not be installed in a Live which already receives data from the same LiveRig Collector (by TCP), otherwise name clashes will occur and the remote control capabilities from the ordinary LiveRig Collector instance will not work due to ambiguous internal events.

Installation

Download the plugin collector reader available at Intelie marketplace:

Verify that the plugin-collector-reader is valid at the plugins page:

Configuration

Search for "collector reader" on Live integrations administration page.

The Collector Reader plugin needs to be configured to consume the same data folder than LiveRig Collector will use to store temporary the data being ingested.

In this case, the folder is /opt/intelie/liverig/data, please confirm the data_path at the liverig.properties file of the LiveRig Collector installation.

This plugin delivers an Extension Type in Live, which enables an arbitrary number of instances for it, so potentially you can monitor the data flow for any number of collectors since they run locally in the same filesystem.

Receiving events

In the example below are two environments configured, side by side, one represented by cloud (left) and the other represented by edge (right) with the plugin-live-collector-reader installed.

The cloud environment is receiving data from a configured collector:

Without configuring the plugin-live-collector-reader it is not expected to receive any data on edge side by executing the query:

__src:(liverig|collector)*

After configuring the integration instance as long as the collector you are pointing to start receiving events those events will be replicated inside live with the field __src set to collector-reader/<qualifier of the instance>.

For example, if your instance's qualifier was set to Rig 01 then you could test the instance is working by running the following pipes query:

__src:"collector-reader/Rig 01"

A typical configuration for a LiveRig collector installed by RPM package will use the folder /opt/intelie/liverig as explained in .

On the image below it is possible to see the online active:

An example of source configuration:

Typical WITSML source configuration
Demonstrating the data arrival in cloud-only environments
Ensures the Collector Reader instance is working fine and receiving data
Collector configuration
collector source
WITSML
Logohttps://marketplace.intelie.com/artifact/plugin-collector-reader