원격 함수

import cwsandbox
from cwsandbox import SandboxDefaults

with cwsandbox.Session(SandboxDefaults(container_image="python:3.11")) as session:
    @session.function()
    def compute(x: int, y: int) -> int:
        return x + y

    # 샌드박스에서 실행
    result = compute.remote(2, 3).result()
    print(result)  # 5

@session.function()
def process_data(data: dict) -> dict:
    # 코드가 샌드박스 내부에서 실행됩니다
    import pandas as pd
    df = pd.DataFrame(data)
    return {"mean": df["value"].mean()}

# OperationRef를 즉시 반환합니다
ref = compute.remote(2, 3)

# 결과가 나올 때까지 대기합니다
result = ref.result()

# 한 줄로 작성
result = compute.remote(2, 3).result()

@session.function()
def square(x: int) -> int:
    return x * x

# 각 입력에 대해 실행
refs = square.map((x,) for x in range(10))

# 모든 결과 수집
from cwsandbox import results
all_results = results(refs)  # [0, 1, 4, 9, 16, 25, 36, 49, 64, 81]

@session.function()
def add(x: int, y: int) -> int:
    return x + y

# 각 튜플은 언패킹되어 인수로 전달됩니다
refs = add.map([(1, 2), (3, 4), (5, 6)])
all_results = results(refs)  # [3, 7, 11]

# 샌드박스를 생성하지 않고 현재 프로세스에서 실행
result = compute.local(2, 3)
print(result)  # 5

@session.function()
def process(data: dict) -> dict:
    return {"result": data["value"] * 2}

@session.function()
def array_mean(values: list[float]) -> float:
    from statistics import fmean
    return fmean(values)

result = array_mean.remote([1.0, 2.0, 3.0, 4.0, 5.0]).result()  # 3.0

multiplier = 10

@session.function()
def multiply(x: int) -> int:
    return x * multiplier  # 'multiplier'를 캡처합니다

result = multiply.remote(5).result()  # 50

CONFIG = {"threshold": 0.5}

@session.function()
def check_value(x: float) -> bool:
    return x > CONFIG["threshold"]

result = check_value.remote(0.7).result()  # True

@session.function(container_image="pytorch/pytorch:latest")
def train_model(data: dict) -> dict:
    import torch
    # GPU 트레이닝 코드
    return {"loss": 0.01}

@session.function()
def failing_function() -> None:
    raise ValueError("Something went wrong")

try:
    failing_function.remote().result()
except Exception as e:
    print(f"Function failed: {e}")

import cwsandbox
from cwsandbox import SandboxDefaults, results

defaults = SandboxDefaults(
    container_image="python:3.11",
    tags=("remote-functions-demo",),
)

with cwsandbox.Session(defaults=defaults) as session:
    @session.function()
    def square(x: int) -> int:
        return x * x

    # 인수는 리스트이고 결과는 float이므로 둘 다 JSON으로 전달할 수 있습니다
    @session.function()
    def array_mean(values: list[float]) -> float:
        from statistics import fmean
        return fmean(values)

    # 단일 실행
    result = square.remote(7).result()
    print(f"7 squared: {result}")

    # 병렬 실행
    refs = square.map((x,) for x in range(5))
    all_results = results(refs)
    print(f"Squares: {all_results}")

    # JSON 호환 연산
    mean = array_mean.remote([1.0, 2.0, 3.0, 4.0, 5.0]).result()
    print(f"Array mean: {mean}")