Skip to content

feat(sample): use JSON input for audience sample #2

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
jradcliff merged 1 commit into from
Jun 18, 2026
Merged

feat(sample): use JSON input for audience sample #2

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
89 changes: 20 additions & 69 deletions samples/IngestAudienceMembers.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,7 @@
// See the License for the specific language governing permissions and
// limitations under the License.

using System.Text.Json;
using CommandLine;
using Google.Ads.DataManager.Util;
using Google.Ads.DataManager.V1;
Expand All @@ -22,7 +23,7 @@ namespace Google.Ads.DataManager.Samples
// <summary>
// Sends a <see cref="IngestAudienceMembersRequest" /> without using encryption.
//
// User data is read from a data file. See the <c>audience_members_1.csv</c> file in the
// User data is read from a data file. See the <c>audience_members_1.json</c> file in the
// <c>sampledata</c> directory for an example.
// </summary>
public class IngestAudienceMembers
Expand Down Expand Up @@ -73,11 +74,11 @@ public class Options
public string AudienceId { get; set; } = null!;

[Option(
"csvFile",
"jsonFile",
Required = true,
HelpText = "Comma-separated file containing user data to ingest"
HelpText = "JSON file containing user data to ingest"
)]
public string CsvFile { get; set; } = null!;
public string JsonFile { get; set; } = null!;

[Option(
"validateOnly",
Expand All @@ -97,7 +98,7 @@ public void Run(Options options)
options.LinkedAccountType,
options.LinkedAccountId,
options.AudienceId,
options.CsvFile,
options.JsonFile,
options.ValidateOnly
);
}
Expand All @@ -111,7 +112,7 @@ private void RunExample(
AccountType? linkedAccountType,
string? linkedAccountId,
string audienceId,
string csvFile,
string jsonFile,
bool validateOnly
)
{
Expand All @@ -130,11 +131,8 @@ bool validateOnly
);
}

// Reads the audience members from the CSV file.
// Each row of the CSV file should be a single audience member.
// The first column of each row should be the email address.
// The second column of each row should be the phone number.
List<Member> memberList = ReadMemberDataFile(csvFile);
// Reads the audience members from the JSON file.
List<Member> memberList = ReadMemberData(jsonFile);

// Creates a factory that will be used to generate the appropriate data manager.
var userDataFormatter = new UserDataFormatter();
Expand All @@ -147,7 +145,7 @@ bool validateOnly
var userDataBuilder = new UserData();

// Adds a UserIdentifier for each valid email address for the member.
foreach (var email in member.EmailAddresses)
foreach (var email in member.Emails)
{
try
{
Expand Down Expand Up @@ -257,6 +255,9 @@ bool validateOnly
},
};

// Logs the request.
Console.WriteLine($"Request #{requestCount}:\n{request}");

// Sends the data to the Data Manager API.
IngestAudienceMembersResponse response =
ingestionServiceClient.IngestAudienceMembers(request);
Expand All @@ -267,66 +268,16 @@ bool validateOnly

private class Member
{
public List<string> EmailAddresses { get; } = new List<string>();
public List<string> PhoneNumbers { get; } = new List<string>();
public List<string> Emails { get; set; } = new List<string>();
public List<string> PhoneNumbers { get; set; } = new List<string>();
}

private List<Member> ReadMemberDataFile(string dataFile)
private List<Member> ReadMemberData(string jsonFile)
{
var members = new List<Member>();
using (var reader = new StreamReader(dataFile))
{
string? line;
int lineNumber = 0;
while ((line = reader.ReadLine()) != null)
{
lineNumber++;
if (line.StartsWith("#"))
// Skips comment row.
continue;

// Expected format:
// email_1,email_2,email_3,phone_1,phone_2,phone_3
string[] columns = line.Split(',');
if (columns[0] == "email_1")
// Skips header row.
continue;

var member = new Member();
for (int col = 0; col < columns.Length; col++)
{
if (string.IsNullOrWhiteSpace(columns[col]))
{
continue;
}

if (col < 3)
{
member.EmailAddresses.Add(columns[col]);
}
else if (col < 6)
{
member.PhoneNumbers.Add(columns[col]);
}
else
{
Console.WriteLine($"Ignoring column index {col} in line #{lineNumber}");
}
}

if (!member.EmailAddresses.Any() && !member.PhoneNumbers.Any())
{
// Skips the row since it contains no user data.
Console.WriteLine($"Ignoring line {lineNumber}. No data.");
}
else
{
// Adds the parsed user data to the list.
members.Add(member);
}
}
}
return members;
string jsonString = File.ReadAllText(jsonFile);
var options = new JsonSerializerOptions { PropertyNameCaseInsensitive = true };
return JsonSerializer.Deserialize<List<Member>>(jsonString, options)
?? new List<Member>();
}
}
}
5 changes: 0 additions & 5 deletions samples/sampledata/audience_members_1.csv
View file
Open in desktop

This file was deleted.

35 changes: 35 additions & 0 deletions samples/sampledata/audience_members_1.json
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,35 @@
[
{
"emails": [
"dana@example.com",
"DanaM@example.com"
]
},
{
"emails": [
"ALEXF@example.com",
"AlexF@cymbalgroup.com",
"alexF@altostrat.com"
],
"phoneNumbers": [
"+1-800-555-0100",
"+1 800-555-0101",
"+1 800-555-0102"
]
},
{
"emails": [
"quinn@CYMBALGROUP.com",
"baklavainthebalkans@gmail.com"
]
},
{
"emails": [
"rosario@example.org",
"cloudySanFrancisco@GMAIL.com"
],
"phoneNumbers": [
"+1-800-555-0110"
]
}
]