Asana エンティティからの読み取り
前提条件
読み取り元の Asana オブジェクト。使用可能なエンティティを確認するには、以下のサポートされているエンティティの表を参照してください。
ソースに対応するエンティティ
| エンティティ | フィルタリング可能 | 制限をサポートする | Order By をサポートする | Select * をサポートする | パーティショニングをサポートする |
|---|---|---|---|---|---|
|
ワークスペース |
なし | あり | なし | あり | なし |
| タグ | なし | あり | なし | あり | なし |
| ユーザー | なし | あり | なし | あり | なし |
|
ポートフォリオ |
なし | あり | なし | あり | なし |
| チーム | なし | あり | なし | あり | なし |
| プロジェクト | はい | あり | なし | あり | なし |
| セクション | なし | あり | なし | あり | なし |
| タスク | あり | なし | なし | あり | あり |
| 目標 | はい | あり | なし | あり | なし |
|
AuditLogEvent |
はい | あり | なし | あり | なし |
|
ステータスの更新 |
はい | あり | なし | あり | なし |
|
カスタムフィールド |
なし | あり | なし | あり | なし |
|
プロジェクトの概要 |
あり | なし | なし | あり | あり |
例
read_read = glueContext.create_dynamic_frame.from_options( connection_type="Asana", connection_options={ "connectionName": "connectionName", "ENTITY_NAME": "task/workspace:xxxx", "API_VERSION": "1.0", "PARTITION_FIELD": "created_at", "LOWER_BOUND": "2024-02-05T14:09:30.115Z", "UPPER_BOUND": "2024-06-07T13:30:00.134Z", "NUM_PARTITIONS": "3" }
Asana エンティティとフィールドの詳細
パーティショニングクエリ
Spark で同時実行を使用する場合は、追加の Spark オプション PARTITION_FIELD、LOWER_BOUND、UPPER_BOUND、および NUM_PARTITIONS を指定できます。これらのパラメータを使用すると、元のクエリは Spark タスクで同時に実行できるサブクエリの NUM_PARTITIONS の数に分割されます。
-
PARTITION_FIELD: クエリのパーティション化に使用するフィールドの名前。 -
LOWER_BOUND: 選択したパーティションフィールドの包括的な下限値。日付については、Spark SQL クエリで使用される Spark の日付形式を受け入れます。有効な値の例:
2024-06-07T13:30:00.134Z。 -
UPPER_BOUND: 選択したパーティションフィールドの排他的上限値。 -
NUM_PARTITIONS: パーティション数。
エンティティごとのパーティション分割フィールドのサポートの詳細は、次の表にまとめられています。
| エンティティ名 | Partitioning Field | データタイプ |
|---|---|---|
| タスク |
created_at |
DateTime |
| タスク |
modified_at |
DateTime |
例
read_read = glueContext.create_dynamic_frame.from_options( connection_type="Asana", connection_options={ "connectionName": "connectionName", "ENTITY_NAME": "task/workspace:xxxx", "API_VERSION": "1.0", "PARTITION_FIELD": "created_at", "LOWER_BOUND": "2024-02-05T14:09:30.115Z", "UPPER_BOUND": "2024-06-07T13:30:00.134Z", "NUM_PARTITIONS": "3" }