Event Management

Correct an ingested event

This API lets you to correct events. Available in both synchronous and asynchronous mode

Usages: Reduction of all usages associated with this event
Revenue: Reduction of all revenues associated with this event
Entitlements: Entitlements(Feature Credits) consumed by this event are granted back to the account.

Possible Actions:

UNDO: Undo all usages, revenue and entitlements associated with an event
REDO: Performs UNDO and re-ingests the same event
REDO_EVENT: Performs UNDO and re-ingests the correction payload of the event

POST

events

correction

curl --request POST \
  --url https://api.togai.com/events/correction \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '{
  "event": {
    "schemaName": "<string>",
    "id": "c0b1306d-f506-43a6-856b-69221efaee6b",
    "timestamp": "2022-06-15T07:30:35.123",
    "accountId": 1,
    "attributes": [
      {
        "name": "message",
        "value": 100,
        "unit": "characters"
      }
    ],
    "dimensions": {}
  }
}'

{
  "data": [
    {
      "referenceId": "event.21OpEx4DHQu.CZlyh",
      "eventPayload": {
        "timestamp": "2023-02-23T14:25:10Z",
        "schemaName": "travelCompletedEvent",
        "id": "c0b1306d-f506-43a6-856b-69221efaee6b",
        "accountId": "1",
        "attributes": [
          {
            "name": "distanceTravelled",
            "value": "50",
            "unit": "Miles"
          },
          {
            "name": "timeSpent",
            "value": "60",
            "unit": "Minutes"
          }
        ],
        "dimensions": {
          "location": "Seattle",
          "costCenterCode": "1234",
          "travelType": "Business"
        }
      },
      "ingestionStatus": {
        "status": "INGESTION_COMPLETED_EVENT_NOT_METERED",
        "statusDescription": "Event ingestion completed successfully but the event is not associated with any bill plan."
      },
      "customerId": "CUS0001",
      "source": {
        "id": "ENTITLED",
        "type": "ENTITLED"
      },
      "createdAt": "2023-02-23T14:25:10Z",
      "status": "REVERTED",
      "reason": "Event Reverted"
    },
    {
      "referenceId": "event.23OrTx4FGQu.XVpzf",
      "eventPayload": {
        "timestamp": "2023-02-23T14:25:10Z",
        "schemaName": "smsSentEvent",
        "id": "sdvb325j-f506-43a6-856b-69221efaee6b",
        "accountId": "1",
        "attributes": [
          {
            "name": "smsCount",
            "value": "50",
            "unit": "count"
          }
        ],
        "dimensions": {}
      },
      "ingestionStatus": {
        "status": "INGESTION_COMPLETED_EVENT_NOT_METERED",
        "statusDescription": "Event ingestion completed successfully but the event is not associated with any bill plan."
      },
      "customerId": "CUS0001",
      "source": {
        "id": "",
        "type": ""
      },
      "createdAt": "2023-01-01T14:25:10Z",
      "status": "FAILED",
      "reason": "Event was ingested in past pricing cycle"
    }
  ]
}

Query Parameters: Allowed filter combinations

All matching events will be considered for correction

Sync mode: Maximum of first 30 events matching the filters with the default sort order being EVENT_SOURCE_TIME DESC, EVENT_ID ASC can be corrected in a single request.
Async mode: When query parameter async = true is given, events matching the filters will be considered for correction and takes place in background.
Status of background job can be obtained using List Jobs API

Authorizations

Authorization

string

header

required

Bearer authentication header of the form Bearer <token>, where <token> is your auth token.

Query Parameters

action

enum<string>

required

Action to perform in event correction

Available options:

UNDO,

REDO,

REDO_EVENT

Example:

"UNDO"

require_confirmation

boolean

Specifies whether to start a migration only after a confirmation

Example:

false

Body

application/json

Event Correction Payload for event correction

event

object

Contents of the event

event.schemaName

string

required

Name of the Event Schema. Know more about event schema

Required string length: 1 - 50

event.timestamp

string

required

Source time stamp of the event. This timestamp must be in ISO 8601 format.

Example:

"2022-06-15T07:30:35.123"

event.accountId

string

required

The event will be associated with the provided account

Maximum length: 512

Example:

1

event.attributes

object[]

required

Attributes are numeric values. It can be usage metric which you push to Togai

Metric to be recorded

event.dimensions

object

required

Dimensions are tags/labels associated with the events.

event.id

string

Togai restricts users to ingest events with same id within a period of 45 days. This restriction is common for /entitled API, /ingest API and /ingestBatch API. i.e, an id used on /ingest API will not be allowed on /ingestBatch or /entitled APIs

Maximum length: 512

Example:

"c0b1306d-f506-43a6-856b-69221efaee6b"

Response

200

application/json

Success response

Events Correction response

data

object[]

required

Raw usage event ingested by the business team and the status of the event ingestion.

data.referenceId

string

required

Unique id generated by Togai to identify an event uniquely

data.eventPayload

object

required

Contents of the event

data.eventPayload.schemaName

string

required

Name of the Event Schema. Know more about event schema

Required string length: 1 - 50

data.eventPayload.timestamp

string

required

Source time stamp of the event. This timestamp must be in ISO 8601 format.

Example:

"2022-06-15T07:30:35.123"

data.eventPayload.accountId

string

required

The event will be associated with the provided account

Maximum length: 512

Example:

1

data.eventPayload.attributes

object[]

required

Attributes are numeric values. It can be usage metric which you push to Togai

Metric to be recorded

data.eventPayload.dimensions

object

required

Dimensions are tags/labels associated with the events.

data.eventPayload.id

string

Maximum length: 512

Example:

"c0b1306d-f506-43a6-856b-69221efaee6b"

data.ingestionStatus

object

required

Status about the event ingestion.

data.createdAt

string

required

Created time stamp of the event. This timestamp must be in ISO 8601 format.

Example:

"2022-06-15T07:30:35.123"

data.status

enum<string>

required

Status of the event requested for correction

Available options:

REVERTED,

REVERTED_AND_REINGESTED,

FAILED

data.reason

string

required

Status description of the event requested for correction

data.customerId

string

The associated account belongs to this customer

Maximum length: 50

Example:

"1"

data.source

object

Source of ingestion of event

Get an event using event id Get Togai Metrics

curl --request POST \
  --url https://api.togai.com/events/correction \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '{
  "event": {
    "schemaName": "<string>",
    "id": "c0b1306d-f506-43a6-856b-69221efaee6b",
    "timestamp": "2022-06-15T07:30:35.123",
    "accountId": 1,
    "attributes": [
      {
        "name": "message",
        "value": 100,
        "unit": "characters"
      }
    ],
    "dimensions": {}
  }
}'

{
  "data": [
    {
      "referenceId": "event.21OpEx4DHQu.CZlyh",
      "eventPayload": {
        "timestamp": "2023-02-23T14:25:10Z",
        "schemaName": "travelCompletedEvent",
        "id": "c0b1306d-f506-43a6-856b-69221efaee6b",
        "accountId": "1",
        "attributes": [
          {
            "name": "distanceTravelled",
            "value": "50",
            "unit": "Miles"
          },
          {
            "name": "timeSpent",
            "value": "60",
            "unit": "Minutes"
          }
        ],
        "dimensions": {
          "location": "Seattle",
          "costCenterCode": "1234",
          "travelType": "Business"
        }
      },
      "ingestionStatus": {
        "status": "INGESTION_COMPLETED_EVENT_NOT_METERED",
        "statusDescription": "Event ingestion completed successfully but the event is not associated with any bill plan."
      },
      "customerId": "CUS0001",
      "source": {
        "id": "ENTITLED",
        "type": "ENTITLED"
      },
      "createdAt": "2023-02-23T14:25:10Z",
      "status": "REVERTED",
      "reason": "Event Reverted"
    },
    {
      "referenceId": "event.23OrTx4FGQu.XVpzf",
      "eventPayload": {
        "timestamp": "2023-02-23T14:25:10Z",
        "schemaName": "smsSentEvent",
        "id": "sdvb325j-f506-43a6-856b-69221efaee6b",
        "accountId": "1",
        "attributes": [
          {
            "name": "smsCount",
            "value": "50",
            "unit": "count"
          }
        ],
        "dimensions": {}
      },
      "ingestionStatus": {
        "status": "INGESTION_COMPLETED_EVENT_NOT_METERED",
        "statusDescription": "Event ingestion completed successfully but the event is not associated with any bill plan."
      },
      "customerId": "CUS0001",
      "source": {
        "id": "",
        "type": ""
      },
      "createdAt": "2023-01-01T14:25:10Z",
      "status": "FAILED",
      "reason": "Event was ingested in past pricing cycle"
    }
  ]
}

Introduction

APIs

​Query Parameters: Allowed filter combinations

Authorizations

Query Parameters

Body

Response

Query Parameters: Allowed filter combinations