etl

    0

    1答えて

    は、まあ、私たちは、私は合計で3行を含むの.txt以下のファイルを持っているとしましょう: cat my_file_to_load.txt 993408 Sep 01 12:46:46 2017 Sep 01 12:46:51 2017 ファイルの巨大なログファイルから特定のデータの抽出です。 最初の行はsuccess_rowsの数であり、2番目の行はstart_timeで、3番目の行

    0

    1答えて

    '.js'ファイルからフラットJsonデータを読み込み、メタデータの入力フィールド名に基づいてJSONフィールド(キー)を変更する変換を作成しました。ユーザーが指定したメタデータのターゲットフィールド名。 また、私はステップにメタデータ入力を挿入するために、ETLメタデータインジェクションのステップを使用しています:JSON入力、値の選択/名前変更、Json出力。 変革1:JSONファイルが含まれ

    0

    1答えて

    私は自分のPentahoステップの1つでDB結合を作成しました。環境をOracleからPostgreSQLに移行しています。 PostgreSQLの全く新しいもので、私はバグを取り除くことができません。結合は次のとおりです。 select t.contract, t.calender, t.mspprovider, t.mspcustomer, t.obje

    0

    1答えて

    私はETLプロセスのための合理的なテストを作成しようとしています。 リファレンス/テストの取り込みデータセットが必要と考えています。私はクライアントデータを使用したくありません(これはもう一つの選択肢です)。 このテストデータセットで現在のETLを実行して、参照変換を取得します。そうすれば、ソースコードが変更されたときに、ETLで現在作成されているものへの参照をテストし、回帰が作成されていないこと

    1

    3答えて

    私はDB2ユーティリティを使用してCSVからDB2へのETLプロセスに取り組んでいます。課題は、importコマンドでdb2変数として動的ファイル名を割り当てることです。ここ は、サンプルコード、 connect to database; CREATE OR REPLACE VARIABLE filenamePath VARCHAR(225); SET filenamePath= concat

    0

    2答えて

    SASのLAG機能を使用して、SAS DIへの移行時にコードを複製しようとしましたが、SAS DIではまったく同じ機能はないようです。 現在SAS DI 4.21を使用しており、すぐに4.9まで移動することができます。 だから私の質問は、SAS DIに次のコードを複製する別の方法がありますされています DATA work.dm_chg_bal; SET tmp_bal_chg; FORMAT

    0

    1答えて

    データ品質の問題により失敗したETLジョブを実行しています。 私のソースでは、私の日付の列は文字列形式であり、メソッドを使用してTIMESTAMPに変換して、ターゲットに格納しています。 2016-11-10 06:07:48.633ではなく、1つの日付値(文字列形式)が2016-06-の場合、このジョブは失敗します。間違った値のため、私はタイムスタンプに変換することができず、私の仕事全体が失敗し

    0

    3答えて

    日付範囲の行を、その日付範囲内のすべての日に複数の行に分割する必要があるシナリオがあります。 Informatica powercenterでこのシナリオでターゲットを取得する方法を知っている人はいますか? SOURCE code start date end date ADMISSION 01/01/2017 02:05:11 01/01/2017 04:20:53 TRANSFER

    0

    2答えて

    SSISパッケージを使用してデータを毎日更新しています。次のようにパッケージのロジックは、 は、宛先表に宛先表のすべての行 を挿入し、完全な新しいデータを削除します。 私は私の挿入が失敗した場合、削除ロールバックする方法を見つけるためにしようとしています。私は以下のようにSSISパッケージのトランザクションを使用してみました: しかし、削除SQLタスクが実行された後に、今、私のパッケージには、長い

    0

    1答えて

    スカラでデータ構造を実装したいのですが、私のプログラムで行われている作業を重複排除することができます。このプログラムはakka-scalaフレームワーク上に構築されています。 私のワーカーにメッセージを受け取るたびに、現在処理中のものについてこのデータ構造をチェックします。そのようなメッセージタイプがすでに処理中であれば、そのデータ構造に格納し、処理結果を待つだけです。処理された結果が到着したら、