2013年8月16日金曜日

awsのruby sdkを使ってEMRのジョブステータスを取得する。

↓な感じになる。
以下は直近1日以内のデータのみを取得するよう、'created_after'パラメータに値を指定してます。
#!/usr/bin/env ruby
require 'rubygems'
require 'aws-sdk'

emr=AWS::EMR.new
created_after = Time.at(Time.now().to_i - (24 * 60 * 60)).iso8601
p created_after
resp = emr.client.describe_job_flows({:created_after => created_after})

resp.data[:job_flows].map{ |job|
    p job[:job_flow_id]
    p "    " + job[:name]
    p "    " + job[:log_uri]
    p "    " + job[:execution_status_detail][:state]
    p
}
実行結果例
"hogehoge"
"    hogejob.name"
"    s3n://hoge-log/emr/logs/"
"    COMPLETED"


0 件のコメント:

コメントを投稿