Adobe Marketo Engage エンティティからの読み取り
前提条件
読み取り元の Adobe Marketo Engage オブジェクト。leads、activities、customobjects などのオブジェクト名が必要になります。次の表は、サポートされているエンティティを示しています。
ソース (同期) でサポートされているエンティティ:
| エンティティ | フィルタリング可能 | 制限をサポートする | Order By をサポートする | Select * をサポートする | パーティション分割をサポートする |
|---|---|---|---|---|---|
| leads | あり | あり | なし | あり | なし |
| アクティビティ | あり | あり | なし | あり | なし |
| customobjects | あり | あり | なし | あり | なし |
ソース (非同期) でサポートされているエンティティ:
| エンティティ | フィルタリング可能 | 制限をサポートする | Order By をサポートする | Select * をサポートする | パーティション分割をサポートする |
|---|---|---|---|---|---|
| leads | あり | なし | なし | あり | あり |
| アクティビティ | あり | なし | なし | あり | なし |
| customobjects | あり | なし | なし | あり | あり |
例:
adobe-marketo-engage_read = glueContext.create_dynamic_frame.from_options( connection_type="adobe-marketo-engage", connection_options={ "connectionName": "connectionName", "ENTITY_NAME": "leads", "API_VERSION": "v2", "INSTANCE_URL": "https://539-t**-6**.mktorest.com" }
Adobe Marketo Engage エンティティとフィールドの詳細:
静的メタデータを持つエンティティ:
| エンティティ | フィールド | データ型 | サポートされている演算子 |
|---|---|---|---|
| アクティビティ | sinceDatetime (同期でのみサポート) | DateTime | >= (同期モードの場合のみ) |
| createdAt (非同期でのみサポート) | DateTime | between (非同期モードのみ) | |
| activitiesTypeId | 整数 | = | |
| adobe-marketo-engageGUID | Long | = (同期モードの場合のみ) | |
| leadId | Long | 該当なし | |
| activityDate | DateTime | 該当なし | |
| campaignId | Long | 該当なし | |
| primaryAttributeValueId | 整数 | 該当なし | |
| primaryAttributeValue | 文字列 | 該当なし | |
| 属性 | 文字列 | 該当なし |
動的メタデータを持つエンティティ:
以下のエンティティの場合、Adobe Marketo Engage はメタデータを動的にフェッチするエンドポイントを備えているため、演算子のサポートは各エンティティのデータ型レベルでキャプチャされます。
| エンティティ | データ型 | サポートされている演算子 |
|---|---|---|
| leads | 整数 | = (同期モードの場合のみ) |
| DateTime | between (非同期モードのみ) | |
| 文字列 | = (同期モードの場合のみ) | |
| Long | 該当なし | |
| ブール値 | 該当なし | |
| 日付 | 該当なし | |
| 浮動小数点数 | 該当なし | |
| customobjects | 整数 | 該当なし |
| DateTime | between (非同期モードのみ) | |
| 文字列 | = (同期モードの場合のみ) | |
| 日付 | 該当なし | |
| Long | 該当なし | |
| ブール値 | 該当なし | |
| 浮動小数点数 | 該当なし |
パーティショニングクエリ
Spark で同時実行を使用する場合は、追加の Spark オプション PARTITION_FIELD、LOWER_BOUND、UPPER_BOUND、および NUM_PARTITIONS を指定できます。これらのパラメータを使用すると、元のクエリは Spark タスクで同時に実行できるサブクエリの NUM_PARTITIONS の数に分割されます。
PARTITION_FIELD: クエリのパーティション化に使用するフィールドの名前。LOWER_BOUND: 選択したパーティションフィールドの包括的な下限値。DateTime フィールドでは、ISO 形式の値を受け入れます。
有効な値の例:
"2024-07-01T00:00:00.000Z"UPPER_BOUND: 選択したパーティションフィールドの排他的上限値。NUM_PARTITIONS: パーティション数。
次の表に、エンティティパーティション分割フィールドのサポートの詳細を示します:
| エンティティ名 | パーティション分割フィールド | データ型 |
|---|---|---|
| leads | createdAt | DateTime |
| updateAt | DateTime | |
| customobjects | updatedAt | DateTime |
例:
adobe-marketo-engage_read = glueContext.create_dynamic_frame.from_options( connection_type="adobe-marketo-engage", connection_options={ "connectionName": "connectionName", "ENTITY_NAME": "leads", "API_VERSION": "v1", "PARTITION_FIELD": "createdAt" "LOWER_BOUND": "2024-07-01T00:00:00.000Z" "UPPER_BOUND": "2024-07-02T00:00:00.000Z" "NUM_PARTITIONS": "10" }
