/** * WPML compatibility functions * * @global array $duplicated_posts Array to store the posts being duplicated. * * @package Yoast\WP\Duplicate_Post * @since 3.2 */ add_action( 'admin_init', 'duplicate_post_wpml_init' ); /** * Add handlers for WPML compatibility. */ function duplicate_post_wpml_init() { if ( defined( 'ICL_SITEPRESS_VERSION' ) ) { add_action( 'dp_duplicate_page', 'duplicate_post_wpml_copy_translations', 10, 3 ); add_action( 'dp_duplicate_post', 'duplicate_post_wpml_copy_translations', 10, 3 ); add_action( 'shutdown', 'duplicate_wpml_string_packages', 11 ); } } global $duplicated_posts; // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: Renaming a global variable is a BC break. $duplicated_posts = []; /** * Copy post translations. * * @global SitePress $sitepress Instance of the Main WPML class. * @global array $duplicated_posts Array of duplicated posts. * * @param int $post_id ID of the copy. * @param WP_Post $post Original post object. * @param string $status Status of the new post. */ function duplicate_post_wpml_copy_translations( $post_id, $post, $status = '' ) { global $sitepress; global $duplicated_posts; remove_action( 'dp_duplicate_page', 'duplicate_post_wpml_copy_translations', 10 ); remove_action( 'dp_duplicate_post', 'duplicate_post_wpml_copy_translations', 10 ); $current_language = $sitepress->get_current_language(); $trid = $sitepress->get_element_trid( $post->ID ); if ( ! empty( $trid ) ) { $translations = $sitepress->get_element_translations( $trid ); $new_trid = $sitepress->get_element_trid( $post_id ); foreach ( $translations as $code => $details ) { if ( $code !== $current_language ) { if ( $details->element_id ) { $translation = get_post( $details->element_id ); if ( ! $translation ) { continue; } $new_post_id = duplicate_post_create_duplicate( $translation, $status ); if ( ! is_wp_error( $new_post_id ) ) { $sitepress->set_element_language_details( $new_post_id, 'post_' . $translation->post_type, $new_trid, $code, $current_language ); } } } } // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: see above. $duplicated_posts[ $post->ID ] = $post_id; } } /** * Duplicate string packages. * * @global array() $duplicated_posts Array of duplicated posts. */ function duplicate_wpml_string_packages() { // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: renaming the function would be a BC-break. global $duplicated_posts; foreach ( $duplicated_posts as $original_post_id => $duplicate_post_id ) { // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: using WPML native filter. $original_string_packages = apply_filters( 'wpml_st_get_post_string_packages', false, $original_post_id ); // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: using WPML native filter. $new_string_packages = apply_filters( 'wpml_st_get_post_string_packages', false, $duplicate_post_id ); if ( is_array( $original_string_packages ) ) { foreach ( $original_string_packages as $original_string_package ) { $translated_original_strings = $original_string_package->get_translated_strings( [] ); foreach ( $new_string_packages as $new_string_package ) { $cache = new WPML_WP_Cache( 'WPML_Package' ); $cache->flush_group_cache(); $new_strings = $new_string_package->get_package_strings(); foreach ( $new_strings as $new_string ) { if ( isset( $translated_original_strings[ $new_string->name ] ) ) { foreach ( $translated_original_strings[ $new_string->name ] as $language => $translated_string ) { do_action( // phpcs:ignore WordPress.NamingConventions.PrefixAllGlobals -- Reason: using WPML native filter. 'wpml_add_string_translation', $new_string->id, $language, $translated_string['value'], $translated_string['status'] ); } } } } } } } } meatabase 連携まで:おすすめ工程(常に動く / 途中でも価値が出る) – Raqqa

meatabase 連携まで:おすすめ工程(常に動く / 途中でも価値が出る)

工程1:ShapeAdapterの“箱”だけ(LLMなし、ルール優先)

目的:/nlq/execute が rows を返しつつ、shape判定も返す(Metabaseはまだ繋がない)

  • app/services/shape/
    • base.py:ShapeAdapter interface(id/describe/match/normalize)
    • registry.py:登録・選択(まずルールで確定、ダメならtable.generic)
    • adapters/time_series.py, ranking.py, scalar.py, table.py(最低4つ)
  • /nlq/execute のレスポンスに 後方互換で追加
    • shape: {adapter_id, confidence, params}meta かトップレベルに追加(どっちでもOK。あなたのAPI規約に合わせる)

✅ この時点で「固定shapeの拡張方式」が確定して、実装が前に進みます。


工程2:キャッシュ保存(Metabaseに見せるための“安定テーブル”)

目的:rowsをキャッシュテーブルへ保存して、run_idで参照できる

ここがキモで、汎用テーブルにJSONBで突っ込むより、**shapeごとに“安定した縦持ちテーブル”**にすると後がラクです。

例(おすすめ):

  • time_series 用:nlq_cache_timeseries
    • run_id, bucket_date, metric_name, metric_value_num, metric_value_text
  • ranking 用:nlq_cache_ranking
    • run_id, rank, dimension, metric_name, metric_value_num
  • scalar 用:nlq_cache_scalar
    • run_id, key, value_num, value_text, value_date
  • table.generic 用:nlq_cache_kv(最後の逃げ道)
    • run_id, row_idx, col_name, value_text, value_num, value_date

Adapter側に write_cache(normalized) -> cache_ref を持たせる(=プラグインの責務)と拡張が綺麗です。

✅ この時点で「Metabaseカードはrun_idパラメータで引く」が成立します。


工程3:Metabase連結(埋め込みURL生成)

目的:shapeに応じて “固定カードID” を選び、run_idを渡して埋め込む

  • MetabaseSpec(shape→カード/パラメータ名の対応)を追加
  • MetabaseEmbed を呼んで signed/public URL を生成
  • /nlq/executestats.metabase / stats.metabase_items をちゃんと埋める
    (今は null のままなのでここで初めて繋がる)

✅ フロントは「Metabase iframe で表示」が完成します。


工程4:LLMに“選ばせる”(tie-break専用)

目的:拡張性UP。ただし LLMは最終決定者にしない

  • ルールで確定できるなら確定
  • 競合・曖昧時だけ LLM(JSON schema固定)で adapter_id を提案させる
  • サーバ側で必ず検証(列存在/閾値/adapter存在)→ダメなら table.generic

✅ ここで「ShapeAdapterを追加しやすい」が完成します。


工程5:DeciKG “箱”だけ(GraphAdapter Registry)

目的:routeがCYPHER系ならMetabaseではなくGraph表示にできる足場

  • GraphAdapter registry(まずは graph.placeholder だけ)
  • /nlq/execute のレスポンスに execution_kind: "graph"graph: {nodes, edges, meta} を出すだけ

✅ DeciKG未実装でも、UI側は切り替え可能になります。


「一気に」やる場合の現実

一気にやるなら 工程1〜3は同時に触ることになるので、落とし穴はこの3つです:

  • shape判定のブレで cache schema と合わない
  • metabase card 側のパラメータ/型が噛み合わない
  • generic table の格納形式が後で地獄になる

なので、やるなら 最低でも 1→2→3 の順で動作確認しながらが安全です。


次スレッドに持ち越す「決定事項」テンプレ(これで合意すると早い)

  • ShapeAdapter方式で行く(rules優先、LLMはtie-break)
  • 最低shape:time_series / ranking / scalar / table.generic
  • キャッシュは “shape別の安定テーブル + run_id参照”
  • Metabaseは固定カード(shapeごと)+ run_id パラメータ
  • DeciKGはGraphAdapter箱だけ先に作る

Comments

コメントを残す

メールアドレスが公開されることはありません。 が付いている欄は必須項目です