2017-03-09 6 views
0

私はこのような流暢なJSON入力を持っています。fluent-plugin-bigquery:プレースホルダの部分文字列

{ "dateTime": "YYYY-mm-dd HH:MM:SS" } 

このメッセージをGoogle BigQueryテーブルtable_YYYYmmddに保存します。

私は

<match tag> 
    @type bigquery 
    table table_%Y%m%d 
    : 
</match> 

のように設定を書き込むことができます知っているが、JSONメッセージの日付が今日ではありません。 JSONメッセージの日付に従ってレコードを保存したいと思います。

どうすればいいですか?

答えて

0

自己解決。

<filter tag> 
    @type record_transformer 
    enable_ruby true 
    <record> 
    yyyymmdd ${record["dateTime"][0..9].gsub("-", "")} 
    </record> 
</filter> 

<match tag> 
    @type bigquery 
    ignore_unknown_values true 
    table table_${yyyymmdd} 
    : 
</match> 
+0

こんにちは、どうやってbigqueryにストリーミングの問題を修正しましたか?私はあなたのメソッドを試して、私はbigquery APIからエラーを取得しています.tableata.insertAll - > code = 400 message = "無効:宛先テーブルのパーティションtable_name _ $ {date}は許容範囲外です。過去の日数と現在の日付からの0日目 –

+0

@Meta_data設定なしでエラーが発生することはありません。私のレコードを今日以外のテーブルに挿入できます。 –