一括Service Manager
一括サービスを利用して、アカウント内のすべてのキャンペーンの広告グループと広告を効率的に管理します。 Bing Ads .NET、Java、Python SDK には、一括レコードのダウンロードとアップロードの生産性を向上させるためのクラスが用意されています。 たとえば、 BulkServiceManager はダウンロード要求を Bulk サービスに送信し、完了するまでサービスをポーリングし、ファイルをローカル ディレクトリにダウンロードします。 BulkServiceManager では、一般的な要求ヘッダー フィールドも処理されるため、AuthorizationData オブジェクトの Authentication、CustomerId、AccountId、DeveloperToken の各プロパティをサービスごとに 1 回指定できます。 詳細については、「 AuthorizationData の使用 」および「 一括要求 のコード例」を参照してください。
注:
BulkServiceManager は、Bing Ads .NET、Java、Python SDK でのみ使用できます。 SDK を使用するかどうかにかかわらず、 Bulk サービス を直接使用できます。 詳細については、「 一括ダウンロードとアップロード」を参照してください。
一括ファイル リーダーとライター
Bulk ファイルの読み取りと書き込みに独自のファイル パーサーを実装する必要はありません。 BulkFileReader オブジェクトと BulkFileWriter オブジェクトを使用して、BulkEntity 派生クラスの読み取りと書き込みを行うことができます。
注:
BulkServiceManager では、ファイルの代わりにエンティティをアップロードおよびダウンロードするときに、BulkFileReader と BulkFileWriter がバックグラウンドで使用されます。 一時ファイルはバックグラウンドで使用されます。 詳細については、「 作業ディレクトリ」と「BulkServiceManager」を参照してください。
たとえば、次の 拡張テキスト広告 レコードを一括ファイルに書き込むとします。
Type,Status,Id,Parent Id,Campaign,Ad Group,Client Id,Modified Time,Title,Text,Text Part 2,Display Url,Destination Url,Promotion,Device Preference,Ad Format Preference,Name,App Platform,App Id,Final Url,Mobile Final Url,Tracking Template,Custom Parameter,Title Part 1,Title Part 2,Title Part 3,Path 1,Path 2
Format Version,,,,,,,,,,,,,,,6.0,,,,,,,,,,,
Expanded Text Ad,Active,,-1111,ParentCampaignNameGoesHere,AdGroupNameGoesHere,ClientIdGoesHere,,,Find New Customers & Increase Sales!,Start Advertising on Contoso Today.,,,,,False,,,,https://www.contoso.com/womenshoesale,https://mobile.contoso.com/womenshoesale,,{_promoCode}=PROMO1; {_season}=summer,Contoso,Quick & Easy Setup,Seemless Integration,seattle,shoe sale
最初に、BulkExpandedTextAd オブジェクトを作成します(「 Bulk and Campaign Management Entity Map」を参照)。 次に、BulkExpandedTextAd を、次に示すように BulkFileWriter を使用してファイルに書き込むことができます。
var bulkFileWriter = new BulkFileWriter(
filePath: FileDirectory + UploadFileName
);
bulkFileWriter.WriteEntity(bulkExpandedTextAd);
bulkFileWriter.Dispose();
BulkFileWriter bulkFileWriter = new BulkFileWriter(
new File(FileDirectory + UploadFileName)
);
bulkFileWriter.writeEntity(bulkExpandedTextAd);
bulkFileWriter.close();
bulk_file_writer=BulkFileWriter(
file_path=FILE_DIRECTORY+UPLOAD_FILE_NAME
)
bulk_file_writer.write_entity(bulk_expanded_text_ad)
bulk_file_writer.close()
BulkFileReader を使用してローカル ディレクトリから一括アップロード結果ファイルを読み取る例を次に示します。 BulkFileReader を使用して、完全なダウンロード、部分的なダウンロード、またはアップロードの結果を含む一括ファイルを読み取ることができます。
var bulkFileReader = new BulkFileReader(
filePath: bulkFilePath, // Path to the Bulk file
resultFileType: ResultFileType.Upload, // FullDownload, PartialDownload, or Upload
fileFormat: DownloadFileType.Csv // Csv or Tsv
);
var resultEntities = bulkFileReader.ReadEntities().ToList();
var expandedTextAdResults = resultEntities.OfType<BulkExpandedTextAd>().ToList();
OutputBulkExpandedTextAds(expandedTextAdResults);
bulkFileReader.Dispose();
BulkFileReader bulkFileReader = new BulkFileReader(
bulkFilePath, // Path to the Bulk file
ResultFileType.UPLOAD, // FULL_DOWNLOAD, PARTIAL_DOWNLOAD, or UPLOAD
DownloadFileType.CSV // Csv or Tsv
);
BulkEntityIterable resultEntities = bulkFileReader.getEntities();
for (BulkEntity entity : resultEntities) {
if (entity instanceof BulkExpandedTextAd) {
outputBulkBulkExpandedTextAds(Arrays.asList((BulkExpandedTextAd) entity));
}
}
resultEntities.close();
bulkFileReader.close();
def read_entities_from_bulk_file(file_path, result_file_type, file_type):
with BulkFileReader(file_path=file_path, result_file_type=result_file_type, file_type=file_type) as reader:
for entity in reader:
yield entity
def main():
result_entities=[]
entities_generator=read_entities_from_bulk_file(
file_path=bulk_file_path, # Path to the Bulk file
result_file_type=ResultFileType.upload, # full_download, partial_download, or upload
file_type='Csv' # Csv or Tsv
)
for entity in entities_generator:
result_entities.append(entity)
for entity in download_entities:
if isinstance(entity, BulkExpandedTextAd):
output_bulk_expanded_text_ads([entity])
一括およびキャンペーン管理エンティティ マップ
BulkServiceManager、BulkFileReader、BulkFileWriter を使用して BulkServiceManager から読み取られ、BulkFileWriter に書き込まれるすべてのオブジェクトは、BulkCampaign、BulkAdGroup、BulkExpandedTextAd などの BulkEntity 基本クラスから派生します。 可能な限り、一括オブジェクトは、キャンペーン管理オブジェクトと値セットを利用します。たとえば、次の BulkExpandedTextAd には、Campaign Management API ExpandedTextAd オブジェクトが 含まれています。
var uploadEntities = new List<BulkEntity>();
// Map properties in the Bulk file to the BulkExpandedTextAd
var bulkExpandedTextAd = new BulkExpandedTextAd
{
// 'Parent Id' column header in the Bulk file
AdGroupId = adGroupIdKey,
// 'Ad Group' column header in the Bulk file
AdGroupName = "AdGroupNameGoesHere",
// 'Campaign' column header in the Bulk file
CampaignName = "ParentCampaignNameGoesHere",
// 'Client Id' column header in the Bulk file
ClientId = "ClientIdGoesHere",
// Map properties in the Bulk file to the
// ExpandedTextAd object of the Campaign Management service.
ExpandedTextAd = new ExpandedTextAd
{
// 'Ad Format Preference' column header in the Bulk file
AdFormatPreference = "All",
// 'Mobile Final Url' column header in the Bulk file
FinalMobileUrls = new[] {
// Each Url is delimited by a semicolon (;) in the Bulk file
"https://mobile.contoso.com/womenshoesale"
},
// 'Final Url' column header in the Bulk file
FinalUrls = new[] {
// Each Url is delimited by a semicolon (;) in the Bulk file
"https://www.contoso.com/womenshoesale"
},
// 'Id' column header in the Bulk file
Id = null,
// 'Path 1' column header in the Bulk file
Path1 = "seattle",
// 'Path 2' column header in the Bulk file
Path2 = "shoe sale",
// 'Status' column header in the Bulk file
Status = AdStatus.Active,
// 'Text' column header in the Bulk file
Text = "Find New Customers & Increase Sales!",
// 'Text Part 2' column header in the Bulk file
TextPart2 = "Start Advertising on Contoso Today.",
// 'Title Part 1' column header in the Bulk file
TitlePart1 = "Contoso",
// 'Title Part 2' column header in the Bulk file
TitlePart2 = "Quick & Easy Setup",
// 'Title Part 3' column header in the Bulk file
TitlePart3 = "Seemless Integration",
// 'Tracking Template' column header in the Bulk file
TrackingUrlTemplate = null,
// 'Custom Parameter' column header in the Bulk file
UrlCustomParameters = new CustomParameters
{
// Each custom parameter is delimited by a semicolon (;) in the Bulk file
Parameters = new[] {
new CustomParameter(){
Key = "promoCode",
Value = "PROMO1"
},
new CustomParameter(){
Key = "season",
Value = "summer"
},
}
},
},
};
uploadEntities.Add(bulkExpandedTextAd);
var entityUploadParameters = new EntityUploadParameters
{
Entities = uploadEntities,
ResponseMode = ResponseMode.ErrorsAndResults,
ResultFileDirectory = FileDirectory,
ResultFileName = DownloadFileName,
OverwriteResultFile = true,
};
var uploadResultEntities = (await bulkServiceManager.UploadEntitiesAsync(entityUploadParameters)).ToList();
List<BulkEntity> uploadEntities = new ArrayList<BulkEntity>();
// Map properties in the Bulk file to the BulkExpandedTextAd
BulkExpandedTextAd bulkExpandedTextAd = new BulkExpandedTextAd();
// 'Parent Id' column header in the Bulk file
bulkExpandedTextAd.setAdGroupId(adGroupIdKey);
// 'Ad Group' column header in the Bulk file
bulkExpandedTextAd.setAdGroupName("AdGroupNameGoesHere");
// 'Campaign' column header in the Bulk file
bulkExpandedTextAd.setCampaignName("ParentCampaignNameGoesHere");
// 'Client Id' column header in the Bulk file
bulkExpandedTextAd.setClientId("ClientIdGoesHere");
// Map properties in the Bulk file to the
// ExpandedTextAd object of the Campaign Management service.
ExpandedTextAd expandedTextAd = new ExpandedTextAd();
// 'Ad Format Preference' column header in the Bulk file
expandedTextAd.setAdFormatPreference("All");
// 'Mobile Final Url' column header in the Bulk file
// Each Url is delimited by a semicolon (;) in the Bulk file
ArrayOfstring mobileFinalUrls = new ArrayOfstring();
mobileFinalUrls.getStrings().add("https://mobile.contoso.com/womenshoesale");
expandedTextAd.setFinalMobileUrls(mobileFinalUrls);
// 'Final Url' column header in the Bulk file
// Each Url is delimited by a semicolon (;) in the Bulk file
ArrayOfstring finalUrls = new ArrayOfstring();
finalUrls.getStrings().add("https://www.contoso.com/womenshoesale");
expandedTextAd.setFinalUrls(finalUrls);
// 'Id' column header in the Bulk file
expandedTextAd.setId(null);
// 'Path 1' column header in the Bulk file
expandedTextAd.setPath1("seattle");
// 'Path 2' column header in the Bulk file
expandedTextAd.setPath2("shoe sale");
// 'Status' column header in the Bulk file
expandedTextAd.setStatus(AdStatus.ACTIVE);
// 'Text' column header in the Bulk file
expandedTextAd.setText("Find New Customers & Increase Sales!");
// 'Text Part 2' column header in the Bulk file
expandedTextAd.setTextPart2("Start Advertising on Contoso Today.");
// 'Title Part 1' column header in the Bulk file
expandedTextAd.setTitlePart1("Contoso");
// 'Title Part 2' column header in the Bulk file
expandedTextAd.setTitlePart2("Quick & Easy Setup");
// 'Title Part 3' column header in the Bulk file
expandedTextAd.setTitlePart3("Seemless Integration");
// 'Tracking Template' column header in the Bulk file
expandedTextAd.setTrackingUrlTemplate(null);
// 'Custom Parameter' column header in the Bulk file
// Each custom parameter is delimited by a semicolon (;) in the Bulk file
CustomParameters customParameters = new CustomParameters();
ArrayOfCustomParameter arrayOfCustomParameter = new ArrayOfCustomParameter();
CustomParameter customParameterA = new CustomParameter();
customParameterA.setKey("promoCode");
customParameterA.setValue("PROMO1");
arrayOfCustomParameter.getCustomParameters().add(customParameterA);
CustomParameter customParameterB = new CustomParameter();
customParameterB.setKey("season");
customParameterB.setValue("summer");
arrayOfCustomParameter.getCustomParameters().add(customParameterB);
customParameters.setParameters(arrayOfCustomParameter);
expandedTextAd.setUrlCustomParameters(customParameters);
bulkExpandedTextAd.setExpandedTextAd(expandedTextAd);
uploadEntities.add(bulkExpandedTextAd);
EntityUploadParameters entityUploadParameters = new EntityUploadParameters();
entityUploadParameters.setEntities(uploadEntities);
entityUploadParameters.setOverwriteResultFile(true);
entityUploadParameters.setResultFileDirectory(new File(FileDirectory));
entityUploadParameters.setResultFileName(ResultFileName);
entityUploadParameters.setResponseMode(ResponseMode.ERRORS_AND_RESULTS);
BulkEntityIterable uploadResultEntities = bulkServiceManager.uploadEntitiesAsync(
entityUploadParameters,
null,
null
).get();
# Map properties in the Bulk file to the BulkExpandedTextAd
bulk_expanded_text_ad=BulkExpandedTextAd()
# 'Parent Id' column header in the Bulk file
bulk_expanded_text_ad.ad_group_id=AD_GROUP_ID_KEY
# 'Ad Group' column header in the Bulk file
bulk_expanded_text_ad.AdGroupName='AdGroupNameGoesHere'
# 'Campaign' column header in the Bulk file
bulk_expanded_text_ad.CampaignName='ParentCampaignNameGoesHere'
# 'Client Id' column header in the Bulk file
bulk_expanded_text_ad.ClientId='ClientIdGoesHere'
# Map properties in the Bulk file to the
# ExpandedTextAd object of the Campaign Management service.
expanded_text_ad=set_elements_to_none(campaign_service.factory.create('ExpandedTextAd'))
# 'Ad Format Preference' column header in the Bulk file
expanded_text_ad.AdFormatPreference='All'
# 'Mobile Final Url' column header in the Bulk file
# Each Url is delimited by a semicolon (;) in the Bulk file
mobile_final_urls=campaign_service.factory.create('ns3:ArrayOfstring')
mobile_final_urls.string.append('https://mobile.contoso.com/womenshoesale')
expanded_text_ad.FinalUrls=mobile_final_urls
# 'Final Url' column header in the Bulk file
# Each Url is delimited by a semicolon (;) in the Bulk file
final_urls=campaign_service.factory.create('ns3:ArrayOfstring')
final_urls.string.append('https://www.contoso.com/womenshoesale')
expanded_text_ad.FinalUrls=final_urls
# 'Id' column header in the Bulk file
expanded_text_ad.Id=None
# 'Path 1' column header in the Bulk file
expanded_text_ad.Path1='seattle'
# 'Path 2' column header in the Bulk file
expanded_text_ad.Path2='shoe sale'
# 'Status' column header in the Bulk file
expanded_text_ad.Status='Active'
# 'Text' column header in the Bulk file
expanded_text_ad.Text='Find New Customers & Increase Sales!'
# 'Text Part 2' column header in the Bulk file
expanded_text_ad.TextPart2='Start Advertising on Contoso Today.'
# 'Title Part 1' column header in the Bulk file
expanded_text_ad.TitlePart1='Contoso'
# 'Title Part 2' column header in the Bulk file
expanded_text_ad.TitlePart2='Quick & Easy Setup'
# 'Title Part 3' column header in the Bulk file
expanded_text_ad.TitlePart3='Seemless Integration'
# 'Tracking Template' column header in the Bulk file
expanded_text_ad.TrackingUrlTemplate=None
# 'Custom Parameter' column header in the Bulk file
# Each custom parameter is delimited by a semicolon (;) in the Bulk file
custom_parameters=set_elements_to_none(campaign_service.factory.create('CustomParameters'))
array_of_custom_parameter=campaign_service.factory.create('ArrayOfCustomParameter')
custom_parameter_a=set_elements_to_none(campaign_service.factory.create('CustomParameter'))
custom_parameter_a.Key='promoCode'
custom_parameter_a.Value='PROMO1'
array_of_custom_parameter.CustomParameter.append(custom_parameter_a)
custom_parameter_b=set_elements_to_none(campaign_service.factory.create('CustomParameter'))
custom_parameter_b.Key='season'
custom_parameter_b.Value='summer'
array_of_custom_parameter.CustomParameter.append(custom_parameter_b)
custom_parameters.Parameters=array_of_custom_parameter
expanded_text_ad.UrlCustomParameters=custom_parameters
bulk_expanded_text_ad.ad=expanded_text_ad
upload_entities.append(bulk_expanded_text_ad)
entity_upload_parameters=EntityUploadParameters(
entities=upload_entities,
overwrite_result_file=True,
result_file_directory=FILE_DIRECTORY,
result_file_name=RESULT_FILE_NAME,
response_mode='ErrorsAndResults'
)
upload_result_entities=bulk_service_manager.upload_entities(
entity_upload_parameters=entity_upload_parameters,
progress=None
)
delete_valueで更新する
既存の設定を削除するには、Bulk サービスによってそのような文字列が無視されるため、Bulk ファイルに空の文字列 ("") を書き込む必要はありません。 予約された "delete_value" 文字列を使用して、省略可能なフィールドの値を削除またはリセットします。 省略可能なフィールドで予約済みの "delete_value" 文字列を使用すると、前の設定が削除されます。 たとえば、展開テキスト広告レコードの [カスタム パラメーター] フィールドを "delete_value" に設定した場合、以前のカスタム パラメーターはすべて展開テキスト広告から削除されます。 同様に、[拡張テキスト広告] レコードの [追跡テンプレート] フィールドを "delete_value" に設定すると、前の追跡テンプレートが展開されたテキスト広告から削除されます。 "delete_value" の詳細については、「 Bulk File Schema - Update with delete_value」を参照してください。
BulkFileWriter は、該当する場合に "delete_value" を自動的に書き込みます。 SDK は Campaign Management API オブジェクトを Bulk ファイルの内容に マップ するため、他のデータ型のプロパティに対して "delete_value" 文字列を明示的に設定することはできません。 このような場合は、Campaign Management API を使用してオブジェクトを更新する場合と同じ構文を使用できます。 次の例では、UrlCustomParameters を空の CustomParameters オブジェクトに設定することで、SDK は展開テキスト広告レコードの [カスタム パラメーター] フィールドに "delete_value" と書き込みます。 同様に、TrackingUrlTemplate を空の文字列に設定すると、SDK は展開テキスト広告レコードの [追跡テンプレート] フィールドに "delete_value" と書き込みます。 ExpandedTextAd オブジェクト内の構文の例は、キャンペーン管理 API を使用して UpdateAds サービス操作を使用してプリビウス設定を削除する方法と同じです。
重要
Bulk エンティティを作成するときは、空の文字列 ("") または "delete_value" 構文を使用しないでください。 予約された "delete_value" 文字列は、一括レコードの更新にのみ適用されます。 プロパティを設定しないか、null と同等の値に設定する必要があります。
var bulkExpandedTextAd = new BulkExpandedTextAd
{
AdGroupId = adGroupIdKey,
ExpandedTextAd = new ExpandedTextAd
{
Id = expandedTextAdIdKey,
TrackingUrlTemplate = "",
UrlCustomParameters = new CustomParameters { }
},
};
BulkExpandedTextAd bulkExpandedTextAd = new BulkExpandedTextAd();
bulkExpandedTextAd.setAdGroupId(expandedTextAdIdKey);
ExpandedTextAd expandedTextAd = new ExpandedTextAd();
expandedTextAd.setId(adIdKey);
expandedTextAd.setTrackingUrlTemplate("");
CustomParameters customParameters = new CustomParameters();
expandedTextAd.setUrlCustomParameters(customParameters);
bulkExpandedTextAd.setExpandedTextAd(expandedTextAd);
bulk_expanded_text_ad=BulkExpandedTextAd()
bulk_expanded_text_ad.ad_group_id=AD_GROUP_ID_KEY
expanded_text_ad=set_elements_to_none(campaign_service.factory.create('ExpandedTextAd'))
expanded_text_ad.Id=EXPANDED_TEXT_AD_ID_KEY
expanded_text_ad.TrackingUrlTemplate=''
custom_parameters=set_elements_to_none(campaign_service.factory.create('CustomParameters'))
expanded_text_ad.UrlCustomParameters=custom_parameters
bulk_expanded_text_ad.ad=expanded_text_ad
ダウンロードとアップロード
BulkServiceManager では、柔軟な一括ダウンロードおよびアップロード ワークフローがサポートされています。
ダウンロード要求またはアップロード要求を作成すると、 BulkServiceManager によってダウンロード要求が Bulk サービスに送信され、完了するまでサービスをポーリングし、ファイルをローカル ディレクトリにダウンロードします。 たとえば、「 BulkServiceManager を使用したバックグラウンド補完」を参照してください。
ダウンロードまたはアップロード要求を送信し、結果ファイルをダウンロードする準備ができるまでポーリングできます。 たとえば、「 BulkServiceManager を使用して送信およびダウンロードする」を参照してください。
何らかの理由で以前のアプリケーション状態から再開する必要がある場合は、既存のダウンロードまたはアップロード要求識別子を使用し、それを使用して結果ファイルをダウンロードできます。 たとえば、「 BulkServiceManager を使用して結果をダウンロードする」を参照してください。
メモリ内のエンティティをダウンロードしてアップロードする場合も、自分でファイルにエンティティを読み書きする場合でも、BulkServiceManager は一時ファイルの読み取りと書き込みを行います。
BulkServiceManager を使用したバックグラウンド補完
ダウンロード要求またはアップロード要求を作成すると、 BulkServiceManager によってダウンロード要求が Bulk サービスに送信され、完了するまでサービスをポーリングし、ファイルをローカル ディレクトリにダウンロードします。
public async Task RunAsync(AuthorizationData authorizationData)
{
var bulkServiceManager = new BulkServiceManager(authorizationData);
var progress = new Progress<BulkOperationProgressInfo>(x =>
Console.WriteLine(String.Format("{0} % Complete", x.PercentComplete.ToString(CultureInfo.InvariantCulture))));
var downloadParameters = new DownloadParameters
{
CampaignIds = null,
DataScope = DataScope.EntityData,
Entities = DownloadEntity.Keywords,
FileType = DownloadFileType.Csv,
LastSyncTimeInUTC = null,
ResultFileDirectory = FileDirectory,
ResultFileName = ResultFileName,
OverwriteResultFile = false // Set this value true if you want to overwrite the same file.
};
// Sets the time interval in milliseconds between two status polling attempts. The default value is 5000 (5 seconds).
bulkServiceManager.StatusPollIntervalInMilliseconds = 5000;
// Sets the timeout of the HttpClient download operation. The default value is 100000 (100s).
bulkServiceManager.DownloadHttpTimeout = new TimeSpan(0, 0, 100);
// You may optionally cancel the DownloadFileAsync operation after a specified time interval.
// Pass this object to the DownloadFileAsync operation or specify CancellationToken.None.
var tokenSource = new CancellationTokenSource();
tokenSource.CancelAfter(3600000);
// The BulkServiceManager will submit your download request to the Bulk service,
// poll the service until completed, and download the file to your local directory.
var resultFile = await bulkServiceManager.DownloadFileAsync(
parameters: downloadParameters,
progress: progress,
cancellationToken: tokenSource.Token
);
Console.WriteLine(string.Format("Download result file: {0}\n", resultFile));
}
BulkServiceManager bulkServiceManager = new BulkServiceManager(authorizationData);
Progress<BulkOperationProgressInfo> progress = new Progress<BulkOperationProgressInfo>() {
@Override
public void report(BulkOperationProgressInfo value) {
System.out.println(value.getPercentComplete() + "% Complete\n");
}
};
DownloadParameters downloadParameters = new DownloadParameters();
downloadParameters.setCampaignIds(null);
ArrayList<DataScope> dataScope = new ArrayList<DataScope>();
dataScope.add(DataScope.ENTITY_DATA);
downloadParameters.setDataScope(dataScope);
downloadParameters.setFileType(FileType);
downloadParameters.setLastSyncTimeInUTC(null);
ArrayList<DownloadEntity> bulkDownloadEntities = new ArrayList<DownloadEntity>();
bulkDownloadEntities.add(DownloadEntity.KEYWORDS);
downloadParameters.setEntities(bulkDownloadEntities);
downloadParameters.setResultFileDirectory(new File(FileDirectory));
downloadParameters.setResultFileName(ResultFileName);
downloadParameters.setOverwriteResultFile(true); // Set this value true if you want to overwrite the same file.
// Sets the time interval in milliseconds between two status polling attempts. The default value is 5000 (5 seconds).
bulkServiceManager.setStatusPollIntervalInMilliseconds(5000);
// Sets the timeout of the HttpClient download operation. The default value is 100000 (100s).
bulkServiceManager.setDownloadHttpTimeoutInMilliseconds(100000);
// The BulkServiceManager will submit your download request to the Bulk service,
// poll the service until completed, and download the file to your local directory.
// You may optionally cancel the downloadFileAsync operation after a specified time interval.
File resultFile = bulkServiceManager.downloadFileAsync(
downloadParameters,
progress,
null
).get(3600000, TimeUnit.MILLISECONDS);
System.out.printf("Download result file: %s\n", resultFile.getName());
bulk_service_manager = BulkServiceManager(
authorization_data=authorization_data,
# Sets the time interval in milliseconds between two status polling attempts.
# The default value is 5000 (5 seconds).
poll_interval_in_milliseconds = 5000,
environment = ENVIRONMENT,
)
download_parameters = DownloadParameters(
campaign_ids=None,
data_scope=['EntityData'],
entities=entities,
file_type=FILE_TYPE,
last_sync_time_in_utc=None,
result_file_directory = FILE_DIRECTORY,
result_file_name = DOWNLOAD_FILE_NAME,
# Set this value true if you want to overwrite the same file.
overwrite_result_file = True,
# You may optionally cancel the download after a specified time interval.
timeout_in_milliseconds=3600000
)
# The BulkServiceManager will submit your download request to the Bulk service,
# poll the service until completed, and download the file to your local directory.
result_file_path = bulk_service_manager.download_file(
download_parameters=download_parameters,
progress = None
)
print("Download result file: {0}\n".format(result_file_path))
BulkServiceManager を使用して送信およびダウンロードする
ダウンロード要求を送信し、BulkDownloadOperation 結果を使用して状態を追跡します。
public async Task RunAsync(AuthorizationData authorizationData)
{
var bulkServiceManager = new BulkServiceManager(authorizationData);
var submitDownloadParameters = new SubmitDownloadParameters
{
CampaignIds = null,
DataScope = DataScope.EntityData,
Entities = DownloadEntity.Keywords,
FileType = DownloadFileType.Csv,
LastSyncTimeInUTC = null
};
var bulkDownloadOperation = await bulkServiceManager.SubmitDownloadAsync(submitDownloadParameters);
// You may optionally cancel the TrackAsync operation after a specified time interval.
var tokenSource = new CancellationTokenSource();
tokenSource.CancelAfter(3600000);
BulkOperationStatus<DownloadStatus> downloadStatus = await bulkDownloadOperation.TrackAsync(
null,
tokenSource.Token
);
var resultFilePath = await bulkDownloadOperation.DownloadResultFileAsync(
FileDirectory,
ResultFileName,
decompress: true,
overwrite: true // Set this value true if you want to overwrite the same file.
);
Console.WriteLine(String.Format("Download result file: {0}\n", resultFilePath));
}
BulkServiceManager bulkServiceManager = new BulkServiceManager(authorizationData);
SubmitDownloadParameters submitDownloadParameters = new SubmitDownloadParameters();
submitDownloadParameters.setCampaignIds(null);
ArrayList<DataScope> dataScope = new ArrayList<DataScope>();
dataScope.add(DataScope.ENTITY_DATA);
submitDownloadParameters.setDataScope(dataScope);
submitDownloadParameters.setFileType(FileType);
submitDownloadParameters.setLastSyncTimeInUTC(null);
ArrayList<DownloadEntity> bulkDownloadEntities = new ArrayList<DownloadEntity>();
bulkDownloadEntities.add(DownloadEntity.KEYWORDS);
submitDownloadParameters.setEntities(bulkDownloadEntities);
// Submit the download request. You can use the BulkDownloadOperation result to track status yourself using getStatusAsync,
// or use trackAsync to indicate that the application should wait until the download status is completed.
BulkDownloadOperation bulkDownloadOperation = bulkServiceManager.submitDownloadAsync(
submitDownloadParameters,
null
).get();
// You may optionally cancel the trackAsync operation after a specified time interval.
BulkOperationStatus<DownloadStatus> downloadStatus = bulkDownloadOperation.trackAsync(
null
).get(3600000, TimeUnit.MILLISECONDS);
File resultFile = bulkDownloadOperation.downloadResultFileAsync(
new File(FileDirectory),
ResultFileName,
true, // Set this value to true if you want to decompress the ZIP file.
true, // Set this value true if you want to overwrite the named file.
null
).get();
System.out.println(String.format("Download result file: %s\n", resultFile.getName()));
bulk_service_manager = BulkServiceManager(
authorization_data=authorization_data,
poll_interval_in_milliseconds = 5000,
environment = ENVIRONMENT,
)
submit_download_parameters = SubmitDownloadParameters(
data_scope = [ 'EntityData' ],
entities = [ 'Campaigns', 'AdGroups', 'Keywords', 'Ads' ],
file_type = 'Csv',
campaign_ids = None,
last_sync_time_in_utc = None,
performance_stats_date_range = None
)
bulk_download_operation = bulk_service_manager.submit_download(submit_download_parameters)
# You may optionally cancel the track() operation after a specified time interval.
download_status = bulk_download_operation.track(timeout_in_milliseconds=3600000)
result_file_path = bulk_download_operation.download_result_file(
result_file_directory = FILE_DIRECTORY,
result_file_name = DOWNLOAD_FILE_NAME,
decompress = True,
overwrite = True, # Set this value true if you want to overwrite the same file.
timeout_in_milliseconds=3600000 # You may optionally cancel the download after a specified time interval.
)
print("Download result file: {0}\n".format(result_file_path))
BulkServiceManager を使用して結果をダウンロードする
何らかの理由で以前のアプリケーション状態から再開する必要がある場合は、既存のダウンロードまたはアップロード要求識別子を使用し、それを使用して結果ファイルをダウンロードできます。 結果を追跡して、ダウンロード状態が完了したことを確認します。
public async Task RunAsync(AuthorizationData authorizationData)
{
var bulkServiceManager = new BulkServiceManager(authorizationData);
var progress = new Progress<BulkOperationProgressInfo>(x =>
Console.WriteLine(String.Format("{0} % Complete", x.PercentComplete.ToString(CultureInfo.InvariantCulture))));
// You may optionally cancel the TrackAsync operation after a specified time interval.
var tokenSource = new CancellationTokenSource();
tokenSource.CancelAfter(3600000);
var bulkDownloadOperation = new BulkDownloadOperation(requestId, authorizationData);
// Use TrackAsync to indicate that the application should wait to ensure that
// the download status is completed.
var bulkOperationStatus = await bulkDownloadOperation.TrackAsync(null, tokenSource.Token);
var resultFilePath = await bulkDownloadOperation.DownloadResultFileAsync(
FileDirectory,
ResultFileName,
decompress: true,
overwrite: true // Set this value true if you want to overwrite the same file.
);
Console.WriteLine(String.Format("Download result file: {0}", resultFilePath));
Console.WriteLine(String.Format("Status: {0}", bulkOperationStatus.Status));
Console.WriteLine(String.Format("TrackingId: {0}\n", bulkOperationStatus.TrackingId));
}
Progress<BulkOperationProgressInfo> progress = new Progress<BulkOperationProgressInfo>() {
@Override
public void report(BulkOperationProgressInfo value) {
System.out.println(value.getPercentComplete() + "% Complete\n");
}
};
java.lang.String requestId = RequestIdGoesHere;
BulkDownloadOperation bulkDownloadOperation = new BulkDownloadOperation(requestId, authorizationData);
// You may optionally cancel the trackAsync operation after a specified time interval.
BulkOperationStatus<DownloadStatus> downloadStatus = bulkDownloadOperation.trackAsync(
progress,
null
).get(3600000, TimeUnit.MILLISECONDS);
System.out.printf(
"Download Status:\nPercentComplete: %s\nResultFileUrl: %s\nStatus: %s\n",
downloadStatus.getPercentComplete(), downloadStatus.getResultFileUrl(), downloadStatus.getStatus()
);
File resultFile = bulkDownloadOperation.downloadResultFileAsync(
new File(FileDirectory),
ResultFileName,
true, // Set this value to true if you want to decompress the ZIP file
true, // Set this value true if you want to overwrite the same file.
null
).get();
System.out.println(String.format("Download result file: %s", resultFile.getName()));
System.out.println(String.format("Status: %s", downloadStatus.getStatus()));
System.out.println(String.format("TrackingId: %s\n", downloadStatus.getTrackingId()));
request_id = RequestIdGoesHere
bulk_download_operation = BulkDownloadOperation(
request_id = request_id,
authorization_data = authorization_data,
poll_interval_in_milliseconds = 5000,
environment = ENVIRONMENT
)
# Use track() to indicate that the application should wait to ensure that the download status is completed.
# You may optionally cancel the track() operation after a specified time interval.
bulk_operation_status = bulk_download_operation.track(timeout_in_milliseconds=3600000)
result_file_path = bulk_download_operation.download_result_file(
result_file_directory = FILE_DIRECTORY,
result_file_name = DOWNLOAD_FILE_NAME,
decompress = True,
overwrite = True, # Set this value true if you want to overwrite the same file.
timeout_in_milliseconds=3600000 # You may optionally cancel the download after a specified time interval.
)
print("Download result file: {0}\n".format(result_file))
print("Status: {0}\n".format(bulk_operation_status.status))
ポーリングと再試行
適切な間隔でダウンロードとアップロードの結果をポーリングします。 データは誰よりもよく知っている。 たとえば、キーワードが 100 万未満のアカウントをダウンロードする場合は、5 秒から 20 秒の間隔でポーリングすることを検討してください。 アカウントに約 100 万のキーワードが含まれている場合は、5 分待ってから 1 分間隔でポーリングすることを検討してください。 約 400 万個のキーワードを持つアカウントの場合は、10 分待ってから 1 分間隔でポーリングすることを検討してください。
BulkServiceManager は、最初の 5 回の試行で結果ファイルを 1000 ミリ秒間隔で自動的にポーリングし、その動作は構成できません。 StatusPollIntervalInMilliseconds プロパティは、最初の 5 回の試行後の各ポーリング試行の時間間隔を決定します。 例については、上記の 「バックグラウンド補完 」を参照してください。 既定値は 5000 であるため、この値を設定しない場合、 BulkServiceManager は 1、2、3、4、5、10、15、20 など、次のシーケンスでポーリングします。 この値を 10000 に設定すると、 BulkServiceManager は 1、2、3、4、5、15、25、35 などのシーケンスでポーリングします。 ポーリングの最小間隔は 1000 であり、1000 未満の値を指定すると例外がスローされます。
BulkServiceManager は、設定した最大タイムアウト時間まで、アップロード、ダウンロード、ポーリング操作を自動的に再試行します。 最大再試行タイムアウト時間を設定できます。 タイムアウトが指定されていない場合、 BulkServiceManager は、サーバーがタイムアウトまたは内部エラーを返すまで再試行を続行します。 別に、大きなファイルをアップロードまたはダウンロードする場合は、UploadHttpTimeout プロパティまたは DownloadHttpTimeout プロパティを設定することを検討する必要があります。
作業ディレクトリと BulkServiceManager
Bing Ads .NET と Java SDK を使用すると、 BulkServiceManager が一時一括ファイルを格納する作業ディレクトリを設定できます。 たとえば、Bing Ads .NET SDK を使用してエンティティをダウンロードする場合、 BulkEntity オブジェクトを直接操作するだけで、一括ファイルが作業ディレクトリにダウンロードされます。 同様に、エンティティをアップロードすると、一時ファイルが作業ディレクトリに書き込まれ、Bulk サービスにアップロードされます。 別の作業ディレクトリーが指定されていない場合は、システム一時ディレクトリーが使用されます。
Microsoft Azure などのホストされているサービスを使用している場合は、一時ディレクトリの制限を超えないようにする必要があります。 カスタム作業ディレクトリを使用する理由は他にもあります。 WorkingDirectory プロパティを設定することで、BulkServiceManager インスタンスごとに異なる作業ディレクトリを指定できます。 ディレクトリの作成と削除も担当します。 一括エンティティを反復処理したら、作業ディレクトリからファイルをクリーンアップできます。
重要
CleanupTempFiles メソッドは、現在の BulkServiceManager インスタンスによってファイルが作成されたかどうかにかかわらず、作業ディレクトリ内のすべてのファイル (サブディレクトリは削除されません) を削除します。
public async Task RunAsync(AuthorizationData authorizationData)
{
var bulkServiceManager = new BulkServiceManager(authorizationData);
var progress = new Progress<BulkOperationProgressInfo>(x =>
Console.WriteLine(String.Format("{0} % Complete", x.PercentComplete.ToString(CultureInfo.InvariantCulture)))
);
var downloadParameters = new DownloadParameters
{
CampaignIds = null,
DataScope = DataScope.EntityData,
Entities = DownloadEntity.Keywords,
FileType = DownloadFileType.Csv,
LastSyncTimeInUTC = null,
ResultFileDirectory = FileDirectory,
ResultFileName = ResultFileName,
OverwriteResultFile = false // Set this value true if you want to overwrite the same file.
};
// The system temp directory will be used if another working directory is not specified. If you are
// using a hosted service such as Microsoft Azure you'll want to ensure you do not exceed the file or directory limits.
// You can specify a different working directory for each BulkServiceManager instance.
bulkServiceManager.WorkingDirectory = FileDirectory;
// The DownloadEntitiesAsync method returns IEnumerable<BulkEntity>, so the download file will not
// be accessible e.g. for CleanupTempFiles until you iterate over the result e.g. via ToList().
var resultEntities = (await bulkServiceManager.DownloadEntitiesAsync(
downloadParameters
)).ToList();
// The CleanupTempFiles method removes all files (but not sub-directories) within the working directory,
// whether or not the files were created by this BulkServiceManager instance.
bulkServiceManager.CleanupTempFiles();
}
BulkServiceManager bulkServiceManager = new BulkServiceManager(authorizationData);
Progress<BulkOperationProgressInfo> progress = new Progress<BulkOperationProgressInfo>() {
@Override
public void report(BulkOperationProgressInfo value) {
System.out.println(value.getPercentComplete() + "% Complete\n");
}
};
DownloadParameters downloadParameters = new DownloadParameters();
downloadParameters.setCampaignIds(null);
ArrayList<DataScope> dataScope = new ArrayList<DataScope>();
dataScope.add(DataScope.ENTITY_DATA);
downloadParameters.setDataScope(dataScope);
downloadParameters.setFileType(FileType);
downloadParameters.setLastSyncTimeInUTC(null);
ArrayList<DownloadEntity> bulkDownloadEntities = new ArrayList<DownloadEntity>();
bulkDownloadEntities.add(DownloadEntity.KEYWORDS);
downloadParameters.setEntities(bulkDownloadEntities);
downloadParameters.setResultFileDirectory(new File(FileDirectory));
downloadParameters.setResultFileName(ResultFileName);
downloadParameters.setOverwriteResultFile(true); // Set this value true if you want to overwrite the same file.
// The system temp directory will be used if another working directory is not specified. If you are
// using a cloud service such as Microsoft Azure you'll want to ensure you do not exceed the file or directory limits.
// You can specify a different working directory for each BulkServiceManager instance.
bulkServiceManager.setWorkingDirectory(new File(FileDirectory));
// The downloadEntitiesAsync method returns BulkEntityIterable, so the download file will not
// be accessible e.g. for cleanupTempFiles until you iterate over the result and close the BulkEntityIterable instance.
BulkEntityIterable tempEntities = bulkServiceManager.downloadEntitiesAsync(
downloadParameters,
null,
null
).get();
ArrayList<BulkEntity> resultEntities = new ArrayList<BulkEntity>();
for (BulkEntity entity : tempEntities) {
resultEntities.add(entity);
}
tempEntities.close();
// The cleanupTempFiles method removes all files (not sub-directories) within the working directory,
// whether or not the files were created by this BulkServiceManager instance.
bulkServiceManager.cleanupTempFiles();