Muse Spark 1.3とは？Metaの自律型AIエージェントの仕組み・特徴・安全性・使い方を徹底解説

!pip -q install openai

import io, zipfile, requests
from google.colab import userdata
from openai import OpenAI

client = OpenAI(base_url="https://api.meta.ai/v1", api_key=userdata.get("MODEL_API_KEY"))

# pallets/flask を丸ごと取得
z = zipfile.ZipFile(io.BytesIO(requests.get(
    "https://github.com/pallets/flask/archive/refs/heads/main.zip", timeout=60).content))
code = ""
for n in z.namelist():
    if n.endswith(".py") and "/tests/" not in n and "/docs" not in n:
        code += f"\n\n### {n}\n" + z.read(n).decode("utf-8", "ignore")
print("ファイル数:", code.count("\n### "), "/ 文字数:", len(code))

res = client.chat.completions.create(
    model="muse-spark-1.3",
    messages=[
        {"role": "system", "content": "コードベース全体を読み、日本語で回答してください。"},
        {"role": "user", "content": (
            "このリポジトリの構造と主要モジュールの役割、"
            "@app.route で登録したビューがリクエストを受けてレスポンスを返すまでの処理フローを解説して。\n\n"
            + code
        )},
    ],
    max_tokens=8000,            # 推論分を含めて余裕を持たせる
    reasoning_effort="low",     # 要約用途なので推論は浅くてよい
)
msg = res.choices[0].message
print(msg.content or "(本文なし)")
print("\n入力トークン:", res.usage.prompt_tokens, "/ 出力トークン:", res.usage.completion_tokens)

if not msg.content:
    print(msg.model_dump())

ファイル数: 34 / 文字数: 362141
# Flask リポジトリ解説

## 1. 全体構造

`flask-main/` は Flask 本体 + チュートリアル/サンプルです。

```
src/flask/              # 本体
  __init__.py           # 公開APIの re-export
  app.py                # class Flask(App): WSGI層
  sansio/
    app.py              # class App(Scaffold): IO非依存ロジック
    scaffold.py         # class Scaffold: Flask/Blueprint共通基盤
    blueprints.py       # class Blueprint, BlueprintSetupState
  blueprints.py         # WSGI用 Blueprint(AppGroup/cli, send_static_file)
  ctx.py                # class AppContext(+g, after_this_request等)
  globals.py            # current_app/g/request/session プロキシ
  wrappers.py           # Request/Response(Werkzeug拡張)
  config.py             # Config, ConfigAttribute
  sessions.py           # SessionInterface, SecureCookieSessionInterface
  templating.py         # Jinja Environment/Loader, render_*
  json/                 # jsonify/dumps/loads, provider, tag(セッション用)
  helpers.py            # redirect/abort/make_response/flash/send_file等
  signals.py            # blinkerシグナル群
  views.py              # View/MethodView
  logging.py            # create_logger, wsgi_errors_stream
  debughelpers.py       # Debug用エラー説明
  cli.py                # flask run/shell/routes
  testing.py            # FlaskClient/EnvironBuilder/FlaskCliRunner
examples/
  tutorial/flaskr/      # 公式チュートリアル: auth/blog/db
  celery/, javascript/  # 拡張・JS連携例
```

### 主要モジュール役割

| モジュール | 役割 |
|---|---|
| `sansio/scaffold.py` | `route/add_url_rule/endpoint/before|after|teardown_request/context_processor/url_defaults/errorhandler` デコレータと `view_functions/error_handler_spec/before|after_request_funcs` 等辞書の保持。`setupmethod` で初回リクエスト後の変更を禁止 |
| `sansio/app.py` | ルーティング登録(`add_url_rule`→`url_map.add`)、Blueprint登録、`url_for/handle_url_build_error/trap_http_exception/redirect`、Jinja/Config/Logger/JSON初期化。WSGIを知らない |
| `app.py:Flask` | WSGI実装: `wsgi_app/__call__/request_context/test_request_context`、`create_url_adapter/match`、`full_dispatch_request/dispatch_request/preprocess/process_response/finalize/make_response/handle_*_exception/log_exception/do_teardown_*` |
| `sansio/blueprints.py + blueprints.py` | 遅延登録。`Blueprint.add_url_rule/record` で `DeferredSetupFunction` を貯め、`register(app)` で `BlueprintSetupState{url_prefix/subdomain/name_prefix}` を適用し `app.add_url_rule("prefix+rule", "bp.endpoint")`、`_merge_blueprint_funcs` で hook/error/view をマージ |
| `ctx.py:AppContext` | v3.2で `RequestContext` 統合。`app/g/url_adapter/request/session/_after_request_functions` 保有。`push(): _cv_app.set + session.open + match_request`、`pop(): do_teardown_request/appcontext + signal`。`copy()` でバックグラウンド継承 |
| `globals.py` | `ContextVar[AppContext] _cv_app` + `LocalProxy` の `current_app/app_ctx/g/request/session`。`request/session` は `ctx.request/_get_session()` に委譲 |
| `wrappers.py` | `Request(RequestBase)`: `url_rule/view_args/routing_exception/endpoint/blueprint/blueprints/max_*` + `json_module`。`Response(ResponseBase)`: `default_mimetype=text/html` |
| `config.py/sessions.py` | `Config.from_object/pyfile/envvar/mapping/file/namespace`。`SecureCookieSessionInterface`: `itsdangerous.URLSafeTimedSerializer + TaggedJSONSerializer` で署名Cookie |
| `templating.py/json/helpers` | `DispatchingJinjaLoader(app+Blueprints)`、`render_template(_stream)`、`DefaultJSONProvider`、`flash/get_flashed_messages/send_file/url_for` |

## 2. `@app.route` → レスポンスまでのフロー

### 2.1 登録時

```python
@app.route("/", methods=["GET"])
def index(): ...
```

1. `Scaffold.route(rule,**options)` → デコレータが `add_url_rule(rule,endpoint,f)` を呼ぶ。
2. `sansio/app.App.add_url_rule`: `endpoint = f.__name__`既定、`methods={"GET"}`化、`provide_automatic_options`(OPTIONS自動)判定、`Rule(rule, methods, endpoint)` を `self.url_map:werkzeug.routing.Map` に `add`、`self.view_functions[endpoint]=f`。重複上書きは `AssertionError`。
3. Blueprintなら即登録せず `record(lambda s: s.add_url_rule(...))` に積み、`app.register_blueprint(bp)` 時に `BlueprintSetupState.add_url_rule` が `url_prefix/subdomain/defaults` を付加し `app.add_url_rule("bp.endpoint")` する。

静的ファイル用 `static/<filename>` ルールも `Flask.__init__/Blueprint.register` で同様に登録。

### 2.2 リクエスト受信: WSGI〜コンテキスト

`werkzeug.serving/run_simple → Flask.__call__ → wsgi_app(environ,start_response)`:

1. `ctx = request_context(environ)` = `AppContext.from_environ(app,environ)` → `Request(environ)` 生成、`create_url_adapter(request)` で `Map.bind_to_environ`。
2. `ctx.push()`:
   * `_cv_app.set(ctx)`、`appcontext_pushed`送信
   * `session_interface.open_session(app,request)` (なければ `NullSession`)
   * `ctx.match_request()`: `url_adapter.match(return_rule=True)` 成功で `request.url_rule/view_args` 設定、失敗で `request.routing_exception(404/405/Redirect)` 設定。
3. `full_dispatch_request(ctx)`:
   * `request_started`送信
   * `preprocess_request(ctx)`: `url_value_preprocessors → before_request_funcs` を `(None, *reversed(request.blueprints))` 順=Blueprint→App順に実行。非`None`返却があれば即その値をビュー戻り値扱いで中断。`flaskr/auth.load_logged_in_user(before_app_request)` や `login_required` がここに絡む。
   * なければ `dispatch_request(ctx)`:
     * `routing_exception` があれば `raise_routing_exception`(debug時の `FormDataRoutingRedirect`検査含む)
     * `rule.provide_automatic_options and method==OPTIONS` なら `make_default_options_response`
     *  иначе `view_functions[rule.endpoint](**view_args)` を `ensure_sync`(async→asgiref経由同期化)して実行。
4. 例外時は `handle_user_exception → handle_http_exception/handle_exception`: `_find_error_handler(e, blueprints)` で `error_handler_spec[scope][code|None][MRO]`探索、なければ再raise/`InternalServerError(original_exception=e)`化。`got_request_exception`送信、`PROPAGATE_EXCEPTIONS/testing/debug`なら再raise。

### 2.3 レスポンス確定: `finalize_request`

1. `make_response(rv)`: `tuple(body,status,headers)`分解→`str/bytes/iterator→Response`、`dict/list→json.response`、`Response/WSGI callable→force_type`。`None`は`TypeError`。`status/headers`上書き。
2. `process_response(ctx, response)`: `after_this_request`関数→`after_request_funcs(blueprints→app逆順)`→ `session.save_session`(modified/permanentなら`Set-Cookie`、`accessed`なら`Vary:Cookie`)。
3. `request_finished`送信→ `response(environ,start_response)` でWSGI iterable返却。
4. `finally: ctx.pop(exc)`:
   * `do_teardown_request(request.blueprints→App逆順)+request_tearing_down`→`request.close()`
   * `do_teardown_appcontext+appcontext_popped` (`flaskr/db.close_db`等)。エラーは`_CollectErrors`で集約し`BaseExceptionGroup`化。
   * `_cv_app.reset`。

これが `flaskr/blog.index: DB→render_template`、`celery/views: tasks.delay→{"result_id"}`、`js_example/add: jsonify` 全てに共通するパスである。


入力トークン: 80703 / 出力トークン: 2234