Tidoop REST API の使用

コンテンツ :

注 : OAUth2. の X-Auth-Token ような何らかの種類のトークン・ベース認証メカニズムによって API が保護されていると仮定すると、すべてのリクエストにヘッダが含まれています。

GET /tidoop/v1/version

cosmos-tidoop の実行中のバージョンを取得します。

リクエストの例 :

GET http://<tidoop_host>:<tidoop_port>/tidoop/v1/version HTTP/1.1
X-Auth-Token: 3bzH35FFLdapMgVCOdpot23534fa8a

レスポンス例 :

HTTP/1.1 200 OK

{
    "success": "true",
    "version": "0.2.0-next"
}

トップ

POST /tidoop/v1/user/{userId}/jobs

次のパラメータを指定して MapReduce ジョブを実行します :

  • 必要な MapReduce アプリケーションを含む Java jar
  • MapReduce アプリケーションの名前
  • Json 配列としての引数。すなわち引数は空白で区切られ、[...] で囲まれています。入力ディレクトリと出力ディレクトリ以外に引数が必要ない場合は、空("") のままにしてください。

引数のいずれかが HDFS パス、たとえば、入力または出力ディレクトリを参照している場合は、HDFS エンドポイントを含む絶対パスが必要です。

リクエストの例 :

POST http://computing.cosmos.lab.fiware.org:12000/tidoop/v1/user/frb/jobs HTTP/1.1
Content-Type: application/json
X-Auth-Token: 3bzH35FFLdapMgVCOdpot23534fa8a

{
    "jar": "/usr/lib/hadoop-mapreduce/hadoop-mapreduce-examples.jar",
    "class_name": "wordcount",
    "args": ["hdfs://storage.cosmos.lab.fiware.org/user/frb/input","hdfs://storage.cosmos.lab.fiware.org/user/frb/output"]
}

レスポンス例 :

HTTP/1.1 200 OK

{
    "success": "true",
    "job_id": "job_1460639183882_0005"
}

トップ

GET /tidoop/v1/user/{userId}/jobs

指定されたユーザ ID で実行されるすべての MapReduce ジョブの詳細を取得します。

リクエストの例 :

GET http://computing.cosmos.lab.fiware.org:12000/tidoop/v1/user/frb/jobs HTTP/1.1
X-Auth-Token: 3bzH35FFLdapMgVCOdpot23534fa8a

レスポンス例 :

HTTP/1.1 200 OK

{
    "success": "true",
    "jobs": [{
        "job_id": "job_1460639183882_0005",
        "state": "SUCCEEDED",
        "start_time": "1460963556383",
        "user_id": "frb"
    }, {
        "job_id": "job_1460639183882_0004",
        "state": "SUCCEEDED",
        "start_time": "1460959583838",
        "user_id": "frb"
    }]
}

トップ

GET /tidoop/v1/user/{userId}/jobs/{jobId}

指定された MapReduce ジョブの詳細を指定されたユーザ ID で取得します。

リクエストの例 :

GET http://computing.cosmos.lab.fiware.org:12000/tidoop/v1/user/frb/jobs/job_1460639183882_0005 HTTP/1.1
X-Auth-Token: 3bzH35FFLdapMgVCOdpot23534fa8a

レスポンス例 :

HTTP/1.1 200 OK

{
    "success": "true",
    "job": {
        "job_id": "job_1460639183882_0005",
        "state": "SUCCEEDED",
        "start_time": "1460963556383",
        "user_id": "frb",
        "stderr": "...",
        "stdout": "..."
    }
}

特定のジョブの詳細を取得する stderr と、stdout のトレースが返されます。

トップ

DELETE /tidoop/v1/user/{userId}/jobs/{jobId}

指定された MapReduce ジョブを指定されたユーザ ID で削除します。

リクエストの例 :

DELETE http://computing.cosmos.lab.fiware.org:12000/tidoop/v1/user/frb/jobs/job_1460639183882_0005 HTTP/1.1
X-Auth-Token: 3bzH35FFLdapMgVCOdpot23534fa8a

レスポンス例 :

HTTP/1.1 200 OK

{
    "success": "true"
}

トップ