통합 사례 개요

CronBark 의 모니터링 프로토콜은 이벤트 기반 입니다 — 작업 시작 시 start, 끝났을 때 success 또는 fail 핑만 HTTP 로 보내면 됩니다. 따라서 핑을 보낼 수 있는 어떤 작업이든 모니터링 대상이 됩니다. 이 페이지는 대표적인 통합 사례 8가지를 정리합니다.

스케줄러 환경별 가이드

각 환경에서 CronBark 핑을 어떻게 추가하는지 한 페이지씩 정리되어 있습니다.

프레임워크 · 클라우드 · 1회성 작업

다음 4가지 사례는 전용 가이드가 아직 없지만 이미 동작합니다 — 기존 REST API 또는 Python SDK 를 그대로 사용하면 됩니다. 패턴 예시:

Airflow · Dagster · Prefect — Python SDK 컨텍스트로 task 감싸기

import cronbark
 
# Airflow PythonOperator 예시
def run_etl(**ctx):
    with cronbark.monitor(token="<API_TOKEN>"):
        load_to_warehouse()

with 블록이 끝나면 자동으로 success (정상 종료) 또는 fail (예외 발생) 가 보고됩니다. Dagster op · Prefect task 도 동일 패턴.

AWS EventBridge · GCP Cloud Scheduler — HTTP target 직결

EventBridge / Cloud Scheduler 의 HTTP/HTTPS target 으로 ping URL 을 그대로 지정하면 됩니다. 별도 코드 불필요.

Target Type: HTTP
Method:      GET
URL:         https://api.cronbark.com/api/v1/ping/<API_TOKEN>

start / fail 까지 활용하려면 작업 본체에서 추가로 호출 (Lambda 함수 내부 등).

ETL · 데이터 파이프라인 (Spark · Dask · 수동 ingest)

driver 프로세스에서 SDK 한 줄. 긴 작업은 monitor() 컨텍스트가 자동으로 timeout/duration 을 추적해 줍니다.

import cronbark
 
try:
    cronbark.start(token="<API_TOKEN>")
    spark_session.sql(...).write.parquet(...)
    # duration 은 백엔드가 start ping 시각 기준으로 자동 계산
    cronbark.success(token="<API_TOKEN>", output="rows=1.2M, partitions=24")
except Exception as e:
    cronbark.fail(token="<API_TOKEN>", error_message=str(e))
    raise

수동 백업 · 1회성 스크립트

정기 스케줄이 없어도 OK. CronBark 에서 크론잡 등록 시 cron 표현식은 표시용 메타데이터로만 쓰이며, 실제 감지는 핑 기준입니다.

#!/bin/bash
TOKEN=<API_TOKEN>
URL=https://api.cronbark.com/api/v1/ping/$TOKEN
 
curl -fsS $URL/start
if pg_dump prod > /backup/$(date +%F).sql; then
  curl -fsS $URL/success
else
  curl -fsS $URL/fail
fi

더 읽어볼 거리