#!/bin/bash HEX_DIGITS=(0 1 2 3 4 5 6 7 8 9 a b c d e f) generateSignature() { local secret=$1 local timestamp= 2 l o c a l v a l u e = " 2localvalue="{secret}${timestamp}" local md5_hash=$(echo -n "${value}" | md5sum | awk '{print $1}') local formatted_text="" for ((i = 0; i < ${#md5_hash}; i += 2)); do hex_pair=${md5_hash:i:2} dec_value=$((16#$hex_pair)) first_char_index=$((dec_value / 16)) second_char_index=$((dec_value % 16)) formatted_text+="${HEX_DIGITS[first_char_index]}${HEX_DIGITS[second_char_index]}" done echo "$formatted_text" } SECRET=“31cfa56c-02ba-45cc-8502-3f64a7aebb8c” TIMESTAMP= ( d a t e + S I G N A T U R E = (date+SIGNATURE=(generateSignature “$SECRET” “$TIMESTAMP”) API_URL=“http://api-in.stone.netease.com/kuafu/api/v3/form/submit” REQUEST_URL=“ParseError: KaTeX parse error: Expected 'EOF', got '&' at position 27: …wClientId=724\ &̲gwClientUser=wb…{TIMESTAMP} &gwSignature=${SIGNATURE}” headers=‘Content-Type: application/json’ payload=‘{ “processDefId”: “服务器维修:40:229789844”, “variables”: { “是否需要业务处理恢复”: “是”, “是否需要发送通知”: “是”, “priority”: “普通”, “故障描述”: “music-hadoop-720.gy.ntes”, “产品名称”: { “value”: “猛犸大数据平台”, “label”: “猛犸大数据平台”, “key”: “猛犸大数据平台” }, “故障部件”: [“硬盘”, “其他”], “影响”: “理论无影响”, “主题”: “服务器维修-猛犸大数据平台-music-hadoop-720.gy.ntes-硬盘-其他”, “预维修时间”: “2025-04-02 11:26:02”, “自动化处理附件”: “”, “主机名”: “music-hadoop-720.gy.ntes”, “跟踪者”: “ZQ05523” }, “user”: { “account”: “wb.zhangjian17”, “jobNumber”: “ZQ05523”, “mail”: “[email protected]”, “name”: “张建” } }’ response=$(curl -X POST -H “$headers” --data “$payload” “$REQUEST_URL”) if [ $? -eq 0 ]; then echo “Success: $response” else echo “Error occurred: $response” fi 1743577802 echo -n “31cfa56c-02ba-45cc-8502-3f64a7aebb8c1743577802” | md5sum 现在有多台机器需要使用上面的脚本创建工单应该如何操作 public-azkaban-6.gy.ntes public-azkaban-7.gy.ntes public-azkaban-8.gy.ntes public-hive-5.gy.ntes public-hive-6.gy.ntes

<think>嗯，用户有一个Bash脚本，用来通过API创建工单，现在需要将这个脚本应用到多台机器上，比如public-azkaban-6.gy.ntes等。首先，我需要理解这个脚本的功能和结构，然后找出如何扩展它以适应多台机器。 首先，脚本的大致流程是生成签名，构造请求URL，然后发送POST请求。生成签名部分使用了时间戳和密钥进行MD5哈希，然后进行了一些格式转换。构造的请求URL包含时间戳和签名，以及一些其他参数。然后发送JSON负载到API_URL，处理响应。 现在问题是如何在多台机器上运行这个脚本。用户提到的机器有public-azkaban-6到8，public-hive-5到6等。可能的解决方法是参数化主机名，然后循环执行。但需要检查脚本中哪些部分需要根据不同的主机进行修改。 查看脚本中的payload部分，发现有一个字段是“主机名”：“music-hadoop-720.gy.ntes”，这应该是需要替换的部分。用户需要为每台机器修改这个主机名，并可能调整其他相关字段，比如“故障描述”和“主题”中的主机名。 所以，用户需要将主机名作为变量，然后循环遍历这些主机名，执行脚本。可能的步骤是： 1. 将主机名列表存储在一个数组中。 2. 修改脚本中的主机名部分，用变量替换。 3. 对于每个主机名，替换payload中的主机名和相关字段，然后执行API请求。 但原来的脚本是硬编码了主机名，所以需要修改脚本使其接受主机名作为参数或者从循环中读取。 另外，需要注意脚本中的时间戳和签名的生成是否正确，是否每次调用都需要新的时间戳和签名。当前的脚本中，TIMESTAMP可能被设置为某个固定值，或者需要动态生成。在用户提供的脚本中，TIMESTAMP的赋值部分看起来有问题，可能是格式错误。例如： TIMESTAMP= ( d a t e + S I G N A T U R E = (date+SIGNATURE=$(generateSignature “$SECRET” “$TIMESTAMP”) 这部分代码看起来有语法错误，可能是用户在复制时出现了格式问题。正确的应该是： TIMESTAMP=$(date +%s) SIGNATURE=$(generateSignature "$SECRET" "$TIMESTAMP") 所以可能需要先修正脚本中的错误，确保时间戳和签名生成正确。 接下来，针对多台机器的处理，可以将主机名列表放入数组，然后循环处理每个主机名，替换payload中的主机名字段。例如： HOSTS=( "public-azkaban-6.gy.ntes" "public-azkaban-7.gy.ntes" "public-azkaban-8.gy.ntes" "public-hive-5.gy.ntes" "public-hive-6.gy.ntes" ) 然后循环每个HOST，修改payload中的主机名，并执行curl命令。 但是，payload是使用单引号定义的，变量在单引号中不会被扩展。所以需要使用双引号或者使用heredoc，并转义内部的双引号。或者，将payload中的主机名部分用变量替换，例如使用sed命令进行替换。 例如，在循环中： for host in "${HOSTS[@]}"; do # 生成新的payload，替换主机名 new_payload=$(echo "$payload" | sed "s/music-hadoop-720.gy.ntes/$host/g") # 执行curl命令，使用新的payload response=$(curl -X POST -H "$headers" --data "$new_payload" "$REQUEST_URL") # 处理响应 done 但需要注意，payload中可能有多个地方需要替换主机名，比如“故障描述”和“主题”字段也可能包含主机名，所以可能需要同时替换这些部分。 另外，需要确保每次循环生成新的时间戳和签名，因为时间戳变化会影响签名。在原始脚本中，时间戳和签名是在循环外生成的，如果在循环内处理多个主机，可能需要为每个主机生成新的时间戳和签名，否则签名可能过期或无效。 因此，应该将时间戳和签名的生成放在循环内部，每次迭代都生成新的。 总结修改步骤： 1. 修正脚本中的时间戳和签名生成部分的语法错误。 2. 将主机名作为循环变量，遍历所有需要的主机。 3. 在每次循环中，替换payload中的主机名及相关字段。 4. 确保每次循环生成新的时间戳和签名。 另外，可能还需要检查API请求的URL是否正确，是否有其他参数需要调整，比如gwClientId等是否固定，是否需要变化。 可能的脚本修改后的结构如下： 修正后的generateSignature函数，正确的时间戳和签名生成，然后在循环中处理每个主机名。 需要特别注意变量替换时的引号问题，以及确保JSON格式正确。</think>针对多台机器批量创建工单的需求，可按以下步骤操作： $\boxed{步骤分解}$ 1. **修正原始脚本基础问题** ```bash # 原时间戳获取错误修正为 TIMESTAMP=$(date +%s) SIGNATURE=$(generateSignature "$SECRET" "$TIMESTAMP") # 原URL参数拼接错误修正为 REQUEST_URL="${API_URL}?gwClientId=724&gwClientUser=wb.zhangjian17&gwTimestamp=${TIMESTAMP}&gwSignature=${SIGNATURE}" ``` 2. **参数化主机名处理** ```bash #!/bin/bash # 定义主机列表数组 HOSTS=( "public-azkaban-6.gy.ntes" "public-azkaban-7.gy.ntes" "public-azkaban-8.gy.ntes" "public-hive-5.gy.ntes" "public-hive-6.gy.ntes" ) ``` 3. **添加循环处理结构** ```bash for HOST in "${HOSTS[@]}"; do # 生成动态时间戳和签名 TIMESTAMP=$(date +%s) SIGNATURE=$(generateSignature "$SECRET" "$TIMESTAMP") # 构造动态请求URL REQUEST_URL="${API_URL}?gwClientId=724&gwClientUser=wb.zhangjian17&gwTimestamp=${TIMESTAMP}&gwSignature=${SIGNATURE}" # 动态生成payload payload=$(cat <<EOF { "processDefId": "服务器维修:40:229789844", "variables": { "主机名": "$HOST", "故障描述": "$HOST", "主题": "服务器维修-猛犸大数据平台-$HOST-硬盘-其他" }, ... } EOF ) # 发送请求（同上） done ``` $\boxed{关键优化点}$ 1. **动态时间戳**：每次循环生成新时间戳，确保签名有效性 2. **Heredoc生成JSON**：避免引号嵌套问题 ```bash payload=$(cat <<EOF { "key": "value" } EOF ) ``` 3. **错误隔离**：每个主机独立处理异常 ```bash response=$(curl -X POST -H "$headers" --data "$payload" "$REQUEST_URL") if [ $? -ne 0 ]; then echo "[$HOST] 请求失败: $response" >> error.log fi ``` $\boxed{完整改进脚本}$ ```bash #!/bin/bash HEX_DIGITS=(0 1 2 3 4 5 6 7 8 9 a b c d e f) generateSignature() { local secret=$1 local timestamp=$2 local value="${secret}${timestamp}" local md5_hash=$(echo -n "${value}" | md5sum | awk '{print $1}') local formatted_text="" for ((i = 0; i < ${#md5_hash}; i += 2)); do hex_pair=${md5_hash:i:2} dec_value=$((16#$hex_pair)) first_char_index=$((dec_value / 16)) second_char_index=$((dec_value % 16)) formatted_text+="${HEX_DIGITS[first_char_index]}${HEX_DIGITS[second_char_index]}" done echo "$formatted_text" } # 配置参数 SECRET="31cfa56c-02ba-45cc-8502-3f64a7aebb8c" API_URL="http://api-in.stone.netease.com/kuafu/api/v3/form/submit" headers="Content-Type: application/json" # 目标主机列表 HOSTS=( "public-azkaban-6.gy.ntes" "public-azkaban-7.gy.ntes" "public-azkaban-8.gy.ntes" "public-hive-5.gy.ntes" "public-hive-6.gy.ntes" ) for HOST in "${HOSTS[@]}"; do # 生成动态凭证 TIMESTAMP=$(date +%s) SIGNATURE=$(generateSignature "$SECRET" "$TIMESTAMP") REQUEST_URL="${API_URL}?gwClientId=724&gwClientUser=wb.zhangjian17&gwTimestamp=${TIMESTAMP}&gwSignature=${SIGNATURE}" # 动态生成请求体 payload=$(cat <<EOF { "processDefId": "服务器维修:40:229789844", "variables": { "是否需要业务处理恢复": "是", "是否需要发送通知": "是", "priority": "普通", "故障描述": "$HOST", "产品名称": { "value": "猛犸大数据平台", "label": "猛犸大数据平台", "key": "猛犸大数据平台" }, "故障部件": ["硬盘", "其他"], "影响": "理论无影响", "主题": "服务器维修-猛犸大数据平台-$HOST-硬盘-其他", "预维修时间": "2025-04-02 11:26:02", "自动化处理附件": "", "主机名": "$HOST", "跟踪者": "ZQ05523" }, "user": { "account": "wb.zhangjian17", "jobNumber": "ZQ05523", "mail": "[email protected]", "name": "张建" } } EOF ) # 发送请求 response=$(curl -s -X POST -H "$headers" --data "$payload" "$REQUEST_URL") if [ $? -eq 0 ]; then echo "[$HOST] 创建成功: $response" else echo "[$HOST] 创建失败: $response" fi sleep 1 # 避免请求频率过高 done ``` $\boxed{执行方式}$ ```bash chmod +x ticket_script.sh ./ticket_script.sh ``` $\boxed{注意事项}$ 1. **权限验证**：确保脚本执行账号有API调用权限 2. **网络连通性**：确认所有目标机器到API服务器的网络可达 3. **日志记录**：建议添加`>> operation.log 2>&1`重定向输出 4. **频率控制**：适当增加`sleep`间隔避免触发API限流 5. **敏感信息**：建议将SECRET存储在环境变量中而非明文