从邮件摘要到业务智能体：拉美成长型企业如何把 AI 接入真实工作流

Flask>=3.0,<4.0
gunicorn>=22.0,<24.0
google-genai>=1.0

import json
import os

from flask import Flask, jsonify, request
from google import genai
from google.genai.types import GenerateContentConfig

app = Flask(__name__)

client = genai.Client(
    vertexai=True,
    project=os.environ["GOOGLE_CLOUD_PROJECT"],
    location=os.getenv("GOOGLE_CLOUD_LOCATION", "global"),
)
MODEL_ID = os.getenv("MODEL_ID", "gemini-2.5-flash")

SYSTEM_INSTRUCTION = """
You extract shipping data for an operations team.
Return JSON only with these keys:
shipment_id, carrier, origin, destination, eta, exception, confidence.
Use null for missing values. Do not invent information.
confidence must be a number between 0 and 1.
""".strip()


@app.post("/extract")
def extract():
    payload = request.get_json(silent=True) or {}
    email = payload.get("email", "").strip()
    if not email:
        return jsonify({"error": "email is required"}), 400

    response = client.models.generate_content(
        model=MODEL_ID,
        contents=email,
        config=GenerateContentConfig(
            system_instruction=SYSTEM_INSTRUCTION,
            temperature=0,
            response_mime_type="application/json",
        ),
    )

    try:
        result = json.loads(response.text)
    except (TypeError, json.JSONDecodeError):
        return jsonify({"error": "model returned invalid JSON"}), 502

    result["requires_review"] = (
        result.get("confidence", 0) < 0.85
        or bool(result.get("exception"))
    )
    return jsonify(result)


@app.get("/health")
def health():
    return {"status": "ok"}

FROM python:3.12-slim
WORKDIR /app
COPY requirements.txt .
RUN pip install --no-cache-dir -r requirements.txt
COPY app.py .
ENV PORT=8080
CMD exec gunicorn --bind :${PORT} --workers 1 --threads 8 app:app

export PROJECT_ID="your-project-id"
export REGION="us-central1"
export SERVICE_NAME="shipping-email-extractor"

gcloud config set project "$PROJECT_ID"
gcloud services enable run.googleapis.com cloudbuild.googleapis.com aiplatform.googleapis.com

gcloud iam service-accounts create shipping-ai --display-name="Shipping AI runtime"

gcloud projects add-iam-policy-binding "$PROJECT_ID" --member="serviceAccount:shipping-ai@$PROJECT_ID.iam.gserviceaccount.com" --role="roles/aiplatform.user"

gcloud run deploy "$SERVICE_NAME" --source . --region "$REGION" --service-account="shipping-ai@$PROJECT_ID.iam.gserviceaccount.com" --set-env-vars="GOOGLE_CLOUD_PROJECT=$PROJECT_ID,GOOGLE_CLOUD_LOCATION=global,MODEL_ID=gemini-2.5-flash" --allow-unauthenticated

export SERVICE_URL="$(gcloud run services describe "$SERVICE_NAME" --region "$REGION" --format='value(status.url)')"

curl -s "$SERVICE_URL/extract" \
  -H "Content-Type: application/json" \
  -d '{"email":"Shipment LA-2048 left Buenos Aires with carrier ACME Logistics. Destination: Santos. ETA is 2026-04-18. Customs invoice is still missing."}'

{
  "shipment_id": "LA-2048",
  "carrier": "ACME Logistics",
  "origin": "Buenos Aires",
  "destination": "Santos",
  "eta": "2026-04-18",
  "exception": "Customs invoice is missing",
  "confidence": 0.96,
  "requires_review": true
}