我想使用API管理YARN容量队列。我创建了Hadoop的安全策略,我通过curl做了:
hadoop_policy()
{
curl -H "Content-Type: application/json" -u "${ranger_admin}:${ranger_password}" \
-d "{ \
\"allowExceptions\": [], \
\"denyExceptions\": [], \
\"dataMaskPolicyItems\": [], \
\"rowFilterPolicyItems\": [], \
\"denyPolicyItems\": [], \
\"description\": \"Securite HDFS pour l'utilisateur ${user}\", \
\"isAuditEnabled\": true, \
\"isEnabled\": true, \
\"name\": \"user_${user}\", \
\"policyItems\": [ \
{ \
\"accesses\": [ \
{ \
\"isAllowed\": true, \
\"type\": \"read\" \
}, \
{ \
\"isAllowed\": true, \
\"type\": \"write\" \
}, \
{ \
\"isAllowed\": true, \
\"type\": \"execute\" \
} \
], \
\"conditions\": [], \
\"delegateAdmin\": false, \
\"groups\": [], \
\"users\": [\"${user}\"] \
} \
], \
\"resources\": { \
\"path\": { \
\"isExcludes\": false, \
\"isRecursive\": true, \
\"values\": [ \
\"/user/${user}\",\"/apps/hive/warehouse/${user}_*\" \
] \
} \
}, \
\"service\": \"${ranger_cluster}_hadoop\", \
\"version\": 1 \
}" \
${ranger_host}/service/public/v2/api/policy/
if [ $? != 0 ]; then
sortieErreur "Erreur de creation de la politique ${policyService} pour l'utilisateur ${user}" 1
fi
}
我有5个队列,我想通过API管理它们,
如果您正在使用Hadoop 3和Capacity Scheduler,则会有一个新的alpha阶段API来更改调度程序配置。端点是:
RM-URL:PORT / WS / V1 /组/调度-conf的
它还支持队列添加,更新和删除以及常规配置更新。