CDCR API

CDCR API

CDCR API用于控制和監(jiān)視復(fù)制過程。控件操作是在集合級(jí)別執(zhí)行的，即通過使用以下基本URL進(jìn)行API調(diào)用：http://localhost:8983/solr/<collection>/cdcr。

監(jiān)視器操作在核心級(jí)別執(zhí)行，即通過使用以下基本URL進(jìn)行API調(diào)用：http://localhost:8983/solr/<core>/cdcr。

目前，沒有一個(gè)CDCR API調(diào)用具有參數(shù)。

CDCR API入口點(diǎn)（控制）

• <collection>/cdcr?action=STATUS：返回 CDCR 的當(dāng)前狀態(tài)。
• <collection>/cdcr?action=START：啟動(dòng)CDCR復(fù)制
• <collection>/cdcr?action=STOP：停止CDCR復(fù)制。
• <collection>/cdcr?action=ENABLEBUFFER：啟用緩沖更新。
• <collection>/cdcr?action=DISABLEBUFFER：禁用更新的緩沖。

CDCR API入口點(diǎn)（監(jiān)控）

• core/cdcr?action=QUEUES：獲取有關(guān)每個(gè)副本的隊(duì)列以及有關(guān)更新日志的統(tǒng)計(jì)信息。
• core/cdcr?action=OPS：獲取有關(guān)每個(gè)副本的復(fù)制性能（每秒操作）的統(tǒng)計(jì)信息。
• core/cdcr?action=ERRORS：獲取有關(guān)每個(gè)副本的復(fù)制錯(cuò)誤的統(tǒng)計(jì)信息和其他信息。

CDCR控制命令

CDCR STATUS

/collection/cdcr?action=STATUS

CDCR STATUS示例

示例輸入：

 http://host:8983/solr/<collection_name>/cdcr?action=STATUS

示例輸出：

{
  "responseHeader": {
  "status": 0,
  "QTime": 0
  },
  "status": {
  "process": "stopped",
  "buffer": "enabled"
  }
}

ENABLEBUFFER（啟用緩沖區(qū)）

/collection/cdcr?action=ENABLEBUFFER

啟用緩沖區(qū)響應(yīng)表示進(jìn)程的狀態(tài)以及是否啟用緩沖區(qū)的指示。

啟用緩沖區(qū)示例

示例輸入：

http://host:8983/solr/<collection_name>/cdcr?action=ENABLEBUFFER

示例輸出：

{
  "responseHeader": {
  "status": 0,
  "QTime": 0
  },
  "status": {
  "process": "started",
  "buffer": "enabled"
  }
}

DISABLEBUFFER（禁用緩沖區(qū)）

/collection/cdcr?action=DISABLEBUFFER

禁用緩沖區(qū)響應(yīng)：CDCR的狀態(tài)和緩沖區(qū)被禁用的指示。

禁用緩沖區(qū)示例

示例輸入：

http://host:8983/solr/<collection_name>/cdcr?action=DISABLEBUFFER

示例輸出：

{
  "responseHeader": {
  "status": 0,
  "QTime": 0
  },
  "status": {
  "process": "started",
  "buffer": "disabled"
  }
}

CDCR START

/collection/cdcr?action=START

CDCR START響應(yīng)：確認(rèn)CDCR已啟動(dòng)，緩沖狀態(tài)。

CDCR START示例

示例輸入：

http://host:8983/solr/<collection_name>/cdcr?action=START

示例輸出：

{
  "responseHeader": {
  "status": 0,
  "QTime": 0
  },
  "status": {
  "process": "started",
  "buffer": "enabled"
  }
}

CDCR STOP

/collection/cdcr?action=STOP

CDCR STOP響應(yīng)：CDCR的狀態(tài)，包括確認(rèn)CDCR已停止。

CDCR STOP示例

示例輸入：

http://host:8983/solr/<collection_name>/cdcr?action=STOP

示例輸出：

{
  "responseHeader": {
  "status": 0,
  "QTime": 0
  },
  "status": {
  "process": "stopped",
  "buffer": "enabled"
  }
}

CDCR監(jiān)視命令

QUEUES

/core/cdcr?action=QUEUES

隊(duì)列（QUEUES）響應(yīng)

QUEUES輸出內(nèi)容

輸出由列表“隊(duì)列（queues）”組成，其中包含（ZooKeeper）目標(biāo)主機(jī)列表，它們本身包含目標(biāo)集合列表。對(duì)于每個(gè)集合，都提供了隊(duì)列的當(dāng)前大小和最后一次成功處理的更新操作的時(shí)間戳。更新操作的時(shí)間戳是原始時(shí)間戳，即在源SolrCloud上處理此操作的時(shí)間。這允許估計(jì)復(fù)制過程的延遲。

“queues”對(duì)象還包含有關(guān)更新日志的信息，例如磁盤上的更新日志的大小（以字節(jié)為單位）（“tlogTotalSize”），事務(wù)日志文件的數(shù)量（“tlogTotalCount”）以及更新的狀態(tài)日志同步器（“updateLogSynchronizer”）。

QUEUES例子

示例輸入：

http://host:8983/solr/<replica_name>/cdcr?action=QUEUES

示例輸出：

{
  "responseHeader":{
    "status": 0,
    "QTime": 1
  },
  "queues":{
    "127.0.0.1: 40342/solr":{
    "Target_collection":{
        "queueSize": 104,
        "lastTimestamp": "2014-12-02T10:32:15.879Z"
      }
    }
  },
  "tlogTotalSize":3817,
  "tlogTotalCount":1,
  "updateLogSynchronizer": "stopped"
}

OPS

/core/cdcr?action=OPS

OPS響應(yīng)

輸出operationsPerSecond包含一個(gè)（ZooKeeper）目標(biāo)主機(jī)列表，它們本身包含一個(gè)目標(biāo)集合列表。對(duì)于每個(gè)集合，都提供自復(fù)制過程開始以來每秒平均處理的操作數(shù)。這些操作進(jìn)一步分為兩組：添加和刪除操作。

OPS示例

示例輸入：

http://host:8983/solr/<collection_name>/cdcr?action=OPS

示例輸出：

{
  "responseHeader":{
    "status":0,
    "QTime":1
  },
  "operationsPerSecond":{
    "127.0.0.1: 59661/solr":{
      "Target_collection":{
          "all": 297.102944952749052,
          "adds": 297.102944952749052,
          "deletes": 0.0
      }
    }
  }
}

ERRORS

/core/cdcr?action=ERRORS

ERRORS響應(yīng)

輸出由包含（ZooKeeper）目標(biāo)主機(jī)列表的“錯(cuò)誤”列表組成，這些主機(jī)本身包含目標(biāo)集合列表。對(duì)于每個(gè)集合，都會(huì)提供關(guān)于在復(fù)制過程中遇到的錯(cuò)誤的信息，例如復(fù)制器線程遇到的連續(xù)錯(cuò)誤數(shù)，復(fù)制過程開始以來的錯(cuò)誤請(qǐng)求數(shù)或內(nèi)部錯(cuò)誤數(shù)，以及最后一個(gè)錯(cuò)誤列表遇到按時(shí)間戳排序。

ERRORS示例

示例輸入：

http://host:8983/solr/<collection_name>/cdcr?action=ERRORS

示例輸出：

{
  "responseHeader":{
    "status":0,
    "QTime":2
  },
  "errors": {
    "127.0.0.1: 36872/solr":{
      "Target_collection":{
        "consecutiveErrors":3,
        "bad_request":0,
        "internal":3,
        "last":{
          "2014-12-02T11:04:42.523Z":"internal",
          "2014-12-02T11:04:39.223Z":"internal",
          "2014-12-02T11:04:38.22Z":"internal"
        }
      }
    }
  }
}