問題タブ [aws-glue-spark]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
pyspark - 不足している列を AWS Glue DataFrame に追加する
Glue を使用して DynamoDB テーブルを読み込んでいます。動的スキーマが原因で、一部の列が存在しない場合があります。それらを追加すると、次のコードで正常に機能しますが、複数の列を追加する必要がある場合に関数を動的にする方法がわかりません。
助言がありますか？
次のコードは、以下のエラーで失敗しています
行 6 を実行できません: case_df_final = Map.apply(frame=case_df_final, f=AddColumn(case_df_final ,'accessoryTaxIncluded')) トレースバック (最新の呼び出しが最後): ファイル "/tmp/zeppelin_pyspark-4928209310219195923.py", 行 375, exec(code, _zcUserQueryNameSpace) ファイル "" の 6 行目、ファイル "" の 3 行目、AddColumn の TypeError: 'DynamicFrame' オブジェクトは項目の割り当てをサポートしていません