#!/bin/bash


# process_json_data.sh

# 厳格なエラーハンドリングとパイプラインの失敗検出

set -euo pipefail

# 一時ディレクトリの作成とクリーンアップ


# JST 2024年7月29日時点の一般的な方法 [1]

TMP_DIR=$(mktemp -d -t json_proc_XXXXXXXX)
log_file="${TMP_DIR}/process_log.txt"
output_file="${TMP_DIR}/processed_data.json"

# スクリプト終了時に一時ファイルを削除するためのトラップ

trap 'echo "Cleaning up temporary directory: ${TMP_DIR}"; rm -rf "${TMP_DIR}"' ERR EXIT

echo "$(date '+%Y-%m-%d %H:%M:%S JST') - INFO: Script started." | tee -a "${log_file}"
echo "$(date '+%Y-%m-%d %H:%M:%S JST') - INFO: Temporary directory created: ${TMP_DIR}" | tee -a "${log_file}"

# ここに具体的なJSON処理ロジックを記述


# ...

echo "$(date '+%Y-%m-%d %H:%M:%S JST') - INFO: Script finished successfully." | tee -a "${log_file}"

# 例として最終的なログと出力ファイルを表示 (本番では不要な場合が多い)

echo "--- Log Content ---"
cat "${log_file}"
echo "--- Output Content (if any) ---"
[ -f "${output_file}" ] && cat "${output_file}" || echo "No output file generated."

#!/bin/bash


# fetch_data_with_curl.sh (上記のprocess_json_data.sh内で使用する想定)

# APIからJSONデータを安全に取得する関数


# 引数: URL, 出力ファイルパス

fetch_json_data() {
    local url="$1"
    local output_path="$2"
    local max_retries=5
    local delay_seconds=2 # 初期遅延秒数

    echo "$(date '+%Y-%m-%d %H:%M:%S JST') - INFO: Fetching data from: ${url}" | tee -a "${log_file}"

    # curlの主要オプション [2][3]


    # --fail-with-body: HTTPエラー時にレスポンスボディも表示


    # --location: リダイレクトを追跡


    # --retry: リトライ回数


    # --retry-delay: リトライ間の初期遅延（秒）


    # --retry-max-time: リトライ試行の合計最大時間（秒）


    # --cacert: CA証明書バンドルのパス (システムデフォルトを使う場合は省略可)


    # --connect-timeout: 接続試行の最大時間


    # --max-time: 全処理の最大時間

    if ! curl -sS \
              --fail-with-body \
              --location \
              --retry "${max_retries}" \
              --retry-delay "${delay_seconds}" \
              --retry-max-time $((delay_seconds * max_retries * 2)) \
              --connect-timeout 10 \
              --max-time 30 \
              --header "Accept: application/json" \
              --cacert /etc/ssl/certs/ca-certificates.crt \
              "${url}" -o "${output_path}" 2>> "${log_file}"; then
        echo "$(date '+%Y-%m-%d %H:%M:%S JST') - ERROR: Failed to fetch data from ${url} after multiple retries." | tee -a "${log_file}"
        return 1
    fi

    echo "$(date '+%Y-%m-%d %H:%M:%S JST') - INFO: Data successfully fetched to: ${output_path}" | tee -a "${log_file}"
    return 0
}

# 使用例 (この部分はprocess_json_data.shの「具体的なJSON処理ロジック」内に記述)


# API_URL="https://api.example.com/data"


# RAW_DATA_FILE="${TMP_DIR}/raw_data.json"


# if ! fetch_json_data "${API_URL}" "${RAW_DATA_FILE}"; then


#    echo "Data fetching failed. Exiting." | tee -a "${log_file}"


#    exit 1


# fi

#!/bin/bash


# process_data_with_jq.sh (上記のprocess_json_data.sh内で使用する想定)

# JSONデータをjqで処理する関数


# 引数: 入力ファイルパス, 出力ファイルパス

process_json_with_jq() {
    local input_path="$1"
    local output_path="$2"

    echo "$(date '+%Y-%m-%d %H:%M:%S JST') - INFO: Processing JSON data from: ${input_path}" | tee -a "${log_file}"

    # jqコマンドの例 [5]


    # 1. 特定のキーを抽出し、新しいオブジェクトの配列を生成


    #    入力: [{"id": 1, "name": "A", "value": 10}, {"id": 2, "name": "B", "value": 20}]


    #    出力: [{"item_id": 1, "item_name": "A"}, {"item_id": 2, "item_name": "B"}]

    #


    # 2. 条件に基づいてフィルタリングし、特定のフィールドの合計を計算


    #    入力: 上記と同じ


    #    出力: 30 (valueが15未満の合計)

    if ! jq '[ .[] | {item_id: .id, item_name: .name} ]' "${input_path}" > "${output_path}"; then
        echo "$(date '+%Y-%m-%d %H:%M:%S JST') - ERROR: jq processing failed for extraction." | tee -a "${log_file}"
        return 1
    fi
    echo "$(date '+%Y-%m-%d %H:%M:%S JST') - INFO: Initial jq processing completed. Output to ${output_path}" | tee -a "${log_file}"

    # 例: フィルタリングと合計

    local total_value
    total_value=$(jq '[ .[] | select(.value < 15) | .value ] | add' "${input_path}")
    echo "$(date '+%Y-%m-%d %H:%M:%S JST') - INFO: Total value for items less than 15: ${total_value}" | tee -a "${log_file}"

    return 0
}

# 使用例 (この部分はprocess_json_data.shの「具体的なJSON処理ロジック」内に記述)


# RAW_DATA_FILE="${TMP_DIR}/raw_data.json"


# PROCESSED_DATA_FILE="${TMP_DIR}/processed_data.json"

#


# # ダミーデータ作成（テスト用）


# echo '[{"id": 1, "name": "ItemA", "value": 10}, {"id": 2, "name": "ItemB", "value": 20}, {"id": 3, "name": "ItemC", "value": 5}]' > "${RAW_DATA_FILE}"

#


# if ! process_json_with_jq "${RAW_DATA_FILE}" "${PROCESSED_DATA_FILE}"; then


#     echo "JSON processing failed. Exiting." | tee -a "${log_file}"


#     exit 1


# fi

[Unit]
Description=JSON Data Processor Service
Documentation=https://example.com/docs/json_processor
After=network.target

[Service]

# このサービスを実行するユーザーを指定。セキュリティ強化のためroot以外を推奨。

User=json_processor_user
Group=json_processor_group

# スクリプトの作業ディレクトリを指定

WorkingDirectory=/opt/json_processor

# サービスタイプをoneshotに設定 (コマンドが終了するとサービスも終了)

Type=oneshot

# コマンドの実行パス。安全なBashスクリプトへのフルパスを指定。

ExecStart=/bin/bash /opt/json_processor/process_json_data.sh

# サービスが終了してもsystemdがその状態を保持 (timerとの連携に便利)

RemainAfterExit=yes

# 標準出力と標準エラーをjournaldにリダイレクト

StandardOutput=journal
StandardError=journal

[Install]

# このサービスはタイマーによって起動されるため、WantedByにはtimers.targetを指定

WantedBy=timers.target

[Unit]
Description=Run JSON Data Processor every 15 minutes
Requires=json_processor.service

[Timer]

# サービスの起動頻度を設定 (例: 15分ごと) [7]

OnCalendar=*:0/15

# システム起動時の過去の実行を見逃しても、起動時にすぐに実行する

Persistent=true

# 起動するサービスユニット

Unit=json_processor.service

[Install]

# タイマーを有効化することで、システム起動時に自動的に起動される

WantedBy=multi-user.target