ঘটনা পাঠান

ইভেন্ট ডেটা পাঠানোর পদ্ধতির সাথে পরিচিত হওয়ার জন্য আপনি এই কুইকস্টার্টটি অনুসরণ করতে পারেন।

নিম্নলিখিত পরিস্থিতিগুলির যেকোনো একটির জন্য ডেটা ম্যানেজার এপিআই ব্যবহার করুন:

  • আপনার ট্যাগ কনভার্সনের জন্য অতিরিক্ত ডেটা উৎস হিসেবে গুগল অ্যাডস ট্যাগ কনভার্সন অথবা গুগল অ্যানালিটিক্স purchase ইভেন্ট পাঠান, যাতে বিজ্ঞাপনের ইন্টারঅ্যাকশন সিগন্যাল সর্বাধিক করা যায় এবং আপনার ডেটা ও সামগ্রিক পারফরম্যান্স আরও শক্তিশালী হয়।

    এই ফিচারটি সকল গুগল অ্যাডস অ্যাকাউন্টের জন্য উপলব্ধ, কিন্তু এটি শুধুমাত্র অ্যালাওলিস্টে থাকা গুগল অ্যানালিটিক্স প্রপার্টিগুলোর জন্যই ব্যবহার করা যায়। আপনি যদি আপনার গুগল অ্যানালিটিক্স প্রপার্টিটি অ্যালাওলিস্টে যুক্ত করতে আগ্রহী হন, তবে ফর্মটি পূরণ করুন ।

  • গুগল অ্যাডস অফলাইন কনভার্সন অথবা লিডদের জন্য এনহ্যান্সড কনভার্সনের ইভেন্ট ডেটা পাঠান।

আপনি গাইডটির যে সংস্করণটি দেখতে চান, তা বেছে নিন।

  • আপনি যদি এমন কোনো Google অ্যাকাউন্টের ক্রেডেনশিয়াল ব্যবহার করেন যা আপনার পরিচালনা করতে চাওয়া বিজ্ঞাপনদাতা অ্যাকাউন্টগুলোর অন্তর্ভুক্ত একজন ব্যবহারকারী, তাহলে 'বিজ্ঞাপনদাতা' (Advertiser) নির্বাচন করুন।
  • আপনি যদি এমন কোনো Google অ্যাকাউন্টের ক্রেডেনশিয়াল ব্যবহার করেন যা কোনো ডেটা পার্টনার অ্যাকাউন্টের ব্যবহারকারী, এবং আপনি সেইসব বিজ্ঞাপনদাতার অ্যাকাউন্ট পরিচালনা করতে চান যেগুলোর সাথে ডেটা পার্টনার অ্যাকাউন্টের একটি পার্টনার লিঙ্ক রয়েছে, তাহলে ডেটা পার্টনার নির্বাচন করুন।

এই কুইকস্টার্টে, আপনাকে নিম্নলিখিত ধাপগুলো সম্পন্ন করতে হবে:

  1. ইভেন্টের ডেটা গ্রহণ করার জন্য একটি Destination প্রস্তুত করুন।
  2. পাঠানোর জন্য ইভেন্টের ডেটা প্রস্তুত করুন।
  3. ইভেন্টগুলির জন্য একটি IngestionService রিকোয়েস্ট তৈরি করুন।
  4. গুগল এপিআই এক্সপ্লোরার ব্যবহার করে অনুরোধটি পাঠান।
  5. সাফল্য ও ব্যর্থতার প্রতিক্রিয়াগুলো বুঝুন।

গন্তব্যস্থল প্রস্তুত করুন

ডেটা পাঠানোর আগে, আপনাকে ডেটার জন্য অন্তত একটি Destination প্রস্তুত করতে হবে। আপনার ব্যবহারের জন্য এখানে একটি নমুনা Destination হলো:

    {
      "operatingAccount": {
        "accountType": "OPERATING_ACCOUNT_TYPE",
        "accountId": "OPERATING_ACCOUNT_ID"
      },

      "loginAccount": {
        "accountType": "LOGIN_ACCOUNT_TYPE",
        "accountId": "LOGIN_ACCOUNT_ID"
      },

      "productDestinationId": "PRODUCT_DESTINATION_ID"
    }

এখানে একটি Destination ফিল্ডগুলো দেওয়া হলো। আরও বিস্তারিত তথ্য এবং বিভিন্ন পরিস্থিতির জন্য গন্তব্যের উদাহরণ জানতে ‘গন্তব্য কনফিগার করুন’ দেখুন।

operatingAccount

যে অ্যাকাউন্টটি ইভেন্টগুলো গ্রহণ করে।

অতিরিক্ত ডেটা উৎস হিসেবে পাঠানো ইভেন্টগুলোর ক্ষেত্রে, অপারেটিং অ্যাকাউন্টটি একটি গুগল অ্যাডস অ্যাকাউন্ট অথবা একটি গুগল অ্যানালিটিক্স প্রপার্টি হতে পারে।

যদি accountType টি GOOGLE_ANALYTICS_PROPERTY হয়, তাহলে অনুরোধের ক্রেডেনশিয়াল অবশ্যই এমন একজন গুগল অ্যানালিটিক্স ব্যবহারকারীর হতে হবে, যার ওই প্রপার্টির জন্য Editor বা Administrator ভূমিকা রয়েছে।

অফলাইন কনভার্সন এবং লিডের জন্য উন্নত কনভার্সন পেতে হলে, অপারেটিং অ্যাকাউন্টটি অবশ্যই একটি গুগল অ্যাডস অ্যাকাউন্ট হতে হবে।

loginAccount
যে অ্যাকাউন্টে ক্রেডেনশিয়ালের জন্য গুগল অ্যাকাউন্টটি রয়েছে, সেটি একজন ব্যবহারকারী।
productDestinationId

operatingAccount অন্তর্গত যে সত্তাটি ইভেন্টগুলো গ্রহণ করে, তার আইডি।

অতিরিক্ত ডেটা উৎস হিসেবে পাঠানো ইভেন্টগুলির ক্ষেত্রে, productDestinationId অবশ্যই নিম্নলিখিতগুলির মধ্যে একটি হতে হবে:

  1. যে গুগল অ্যাডস কনভার্সনের type WEBPAGE হিসেবে সেট করা আছে, তার আইডি। গুগল অ্যাডস UI-তে, একটি WEBPAGE কনভার্সন অ্যাকশনের জন্য কনভার্সন সোর্স হলো Website ।

  2. গুগল অ্যানালিটিক্স ওয়েব স্ট্রিমের মেজারমেন্ট আইডি । আপনি গুগল অ্যানালিটিক্স আইওএস অ্যাপ বা অ্যান্ড্রয়েড অ্যাপ স্ট্রিমে অতিরিক্ত ডেটা সোর্স হিসেবে ইভেন্ট পাঠাতে পারবেন না।

অফলাইন কনভার্সন বা লিডদের জন্য এনহ্যান্সড কনভার্সনের ক্ষেত্রে, productDestinationId অবশ্যই এমন একটি Google Ads কনভার্সন অ্যাকশনের আইডি হতে হবে যার type UPLOAD_CLICKS হিসেবে সেট করা আছে। Google Ads UI-তে, একটি UPLOAD_CLICKS কনভার্সন অ্যাকশনের জন্য কনভার্সন সোর্স হলো Website (Import from clicks) ।

এই নির্দেশিকার উদাহরণে দেখানো হয়েছে কীভাবে এমন একটি অনুরোধ তৈরি করতে হয় যা প্রতিটি ইভেন্টকে একই গন্তব্যে পাঠায়। আপনি যদি একই অনুরোধে একাধিক গন্তব্যের জন্য ইভেন্ট পাঠাতে চান, তাহলে "একাধিক গন্তব্যের জন্য ইভেন্ট পাঠান" দেখুন।

ইভেন্টের ডেটা প্রস্তুত করুন

নিম্নলিখিত ইভেন্ট ডেটা বিবেচনা করুন। প্রতিটি টেবিল একটি রূপান্তর ইভেন্টের সাথে সম্পর্কিত। প্রতিটি রূপান্তর ইভেন্টে ইভেন্টের টাইমস্ট্যাম্প, এর রূপান্তর অ্যাকশন এবং রূপান্তর মান রয়েছে।

প্রতিটি ইভেন্টে বিজ্ঞাপন শনাক্তকারী (ad identifiers), যেমন gclid , অথবা ব্যবহারকারী শনাক্তকারী (user identifiers), যেমন ইমেল ঠিকানা, ফোন নম্বর এবং ঠিকানার তথ্য থাকতে পারে। একটি ইভেন্টে আরও থাকতে পারে:

এখানে ইভেন্টের তথ্য দেওয়া হলো:

ঘটনা ১

ইভেন্ট #১
conversion_time 2025-06-10 15:07:01-05:00
conversion_action_id 123456789
transaction_id ABC798654321
conversion_value 30.03
currency USD
gclid GCLID_1
emails
given_name John
family_name Smith-Jones
region_code us
postal_code 94045
customer_type NEW
customer_value_bucket HIGH
client_id 1234567890.1761581763
user_id user_ABC12345
ad_unit_name Banner_01
event_name purchase
কার্টের আইটেমগুলি
item_id SKU_12345
item_name Stan and Friends Tee
item_affiliation Google Merchandise Store
item_coupon SUMMER_FUN
item_discount 2.22
item_index 0
item_brand Google
item_category Apparel
item_category2 Adult
item_category3 Shirts
item_category4 Crew
item_category5 Short sleeve
item_list_id related_products
item_list_name Related Products
item_price 10.01
item_quantity 3

ঘটনা ২

ইভেন্ট #২
conversion_time June 10, 2025 11:42:33PM America/New_York
conversion_action_id 123456789
transaction_id DEF999911111
conversion_value 42.02
currency eur
gclid GCLID_2
emails

zoe@EXAMPLE.COM

cloudy.sanfrancisco@gmail.com

given_name zoë
family_name pérez
region_code PT
postal_code 1229-076
customer_type RETURNING
client_id 9876543210.1761582117
user_id user_DEF9876
ad_unit_name Banner_02
event_name purchase
কার্টের আইটেমগুলি
item_id SKU_12346
item_name Google Grey Women's Tee
item_affiliation Google Merchandise Store
item_coupon SUMMER_FUN
item_discount 3.33
item_index 1
item_brand Google
item_category Apparel
item_category2 Adult
item_category3 Shirts
item_category4 Crew
item_category5 Short sleeve
item_list_id related_products
item_list_name Related Products
item_price 21.01
item_quantity 2

ডেটা ফরম্যাট করুন

ফরম্যাটিং গাইডে উল্লেখিত নির্দেশনা অনুযায়ী ফিল্ডগুলো ফরম্যাট করুন। ফরম্যাট করার পর ইভেন্টের ডেটা নিচে দেওয়া হলো:

ঘটনা ১

ইভেন্ট #১
conversion_time 2025-06-10T15:07:01-05:00
conversion_action_id 123456789
transaction_id ABC798654321
conversion_value 30.03
currency USD
gclid GCLID_1
emails
given_name john
family_name smith-jones
region_code US
postal_code 94045
customer_type NEW
customer_value_bucket HIGH
client_id 1234567890.1761581763
user_id user_ABC12345
ad_unit_name Banner_01
event_name purchase
কার্টের আইটেমগুলি
item_id SKU_12345
item_name Stan and Friends Tee
item_affiliation Google Merchandise Store
item_coupon SUMMER_FUN
item_discount 2.22
item_index 0
item_brand Google
item_category Apparel
item_category2 Adult
item_category3 Shirts
item_category4 Crew
item_category5 Short sleeve
item_list_id related_products
item_list_name Related Products
item_price 10.01
item_quantity 3

ঘটনা ২

ইভেন্ট #২
conversion_time 2025-06-10T23:42:33-05:00
conversion_action_id 123456789
transaction_id DEF999911111
conversion_value 42.02
currency EUR
gclid GCLID_2
emails

zoe@example.com

cloudysanfrancisco@gmail.com

given_name zoë
family_name pérez
region_code PT
postal_code 1229-076
customer_type RETURNING
client_id 9876543210.1761582117
user_id user_DEF9876
ad_unit_name Banner_02
event_name purchase
কার্টের আইটেমগুলি
item_id SKU_12346
item_name Google Grey Women's Tee
item_affiliation Google Merchandise Store
item_coupon SUMMER_FUN
item_discount 3.33
item_index 1
item_brand Google
item_category Apparel
item_category2 Adult
item_category3 Shirts
item_category4 Crew
item_category5 Short sleeve
item_list_id related_products
item_list_name Related Products
item_price 21.01
item_quantity 2

ডেটা হ্যাশ এবং এনকোড করুন

এছাড়াও, ফরম্যাট করা ইমেল ঠিকানা, প্রদত্ত নাম এবং পারিবারিক নাম অবশ্যই SHA-256 অ্যালগরিদম ব্যবহার করে হ্যাশ করতে হবে এবং হেক্স অথবা Base64 এনকোডিং ব্যবহার করে এনকোড করতে হবে। ফরম্যাটিং, হ্যাশিং এবং হেক্স এনকোডিং ব্যবহার করে এনকোড করার পরের ইভেন্ট ডেটা নিচে দেওয়া হলো:

ঘটনা ১

ইভেন্ট #১
conversion_time 2025-06-10T15:07:01-05:00
conversion_action_id 123456789
transaction_id ABC798654321
conversion_value 30.03
currency USD
gclid GCLID_1
emails
given_name 96D9632F363564CC3032521409CF22A852F2032EEC099ED5967C0D000CEC607A
family_name DB98D2607EFFFA28AFF66975868BF54C075ECA7157E35064DCE08E20B85B1081
region_code US
postal_code 94045
customer_type NEW
customer_value_bucket HIGH
client_id 1234567890.1761581763
user_id user_ABC12345
ad_unit_name Banner_01
event_name purchase
কার্টের আইটেমগুলি
item_id SKU_12345
item_name Stan and Friends Tee
item_affiliation Google Merchandise Store
item_coupon SUMMER_FUN
item_discount 2.22
item_index 0
item_brand Google
item_category Apparel
item_category2 Adult
item_category3 Shirts
item_category4 Crew
item_category5 Short sleeve
item_list_id related_products
item_list_name Related Products
item_price 10.01
item_quantity 3

ঘটনা ২

ইভেন্ট #২
conversion_time 2025-06-10T23:42:33-05:00
conversion_action_id 123456789
transaction_id DEF999911111
conversion_value 42.02
currency EUR
gclid GCLID_2
emails

3E693CF7E5B67880BFF33B2D2626DADB7BF1D4BC737192E47CF8BAA89ACF2250

223EBDA6F6889B1494551BA902D9D381DAF2F642BAE055888E96343D53E9F9C4

given_name 2752B88686847FA5C86F47B94CE652B7B3F22A91C37617D451A4DB9AFA431450
family_name 6654977D57DDDD3C0329CA741B109EF6CD6430BEDD00008AAD213DF25683D77F
region_code PT
postal_code 1229-076
customer_type RETURNING
client_id 9876543210.1761582117
user_id user_DEF9876
ad_unit_name Banner_02
event_name purchase
কার্টের আইটেমগুলি
item_id SKU_12346
item_name Google Grey Women's Tee
item_affiliation Google Merchandise Store
item_coupon SUMMER_FUN
item_discount 3.33
item_index 1
item_brand Google
item_category Apparel
item_category2 Adult
item_category3 Shirts
item_category4 Crew
item_category5 Short sleeve
item_list_id related_products
item_list_name Related Products
item_price 21.01
item_quantity 2

ডেটাগুলোকে Event অবজেক্টে রূপান্তর করুন

প্রতিটি ইভেন্টের ফরম্যাট করা এবং হ্যাশ করা ডেটাকে একটি Event রূপান্তর করুন। নির্দেশ অনুযায়ী নিম্নলিখিত ফিল্ডগুলি পূরণ করুন:

  1. ইভেন্টটি ঘটার সময়ে eventTimestamp সেট করুন।

    গুগল অ্যানালিটিক্সের জন্য ইভেন্টগুলোতে অবশ্যই গত ৭২ ঘণ্টার মধ্যেকার একটি eventTimestamp থাকতে হবে।

  2. আপনার ব্যবহারের ক্ষেত্র অনুযায়ী প্রয়োজনীয় ফিল্ডগুলো সেট করুন।

    ব্যবহারের ক্ষেত্র শনাক্তকারী transactionId eventSource
    লিডগুলির জন্য অফলাইন রূপান্তর বা উন্নত রূপান্তর আবশ্যক । নিম্নলিখিতগুলির মধ্যে অন্তত একটি সেট করুন: ঐচ্ছিক আবশ্যক । EventSource জন্য enum মানগুলির মধ্যে একটিতে সেট করুন।
    গুগল অ্যাডস ডেস্টিনেশনে অতিরিক্ত ডেটা উৎস হিসেবে পাঠানো ইভেন্টসমূহ আবশ্যক । নিম্নলিখিতগুলির মধ্যে অন্তত একটি সেট করুন:
    • adIdentifiers যেখানে gclid , gbraid , বা wbraid এর মধ্যে অন্তত একটি সেট করা আছে
    • userData
    		 প্রয়োজনীয় ঐচ্ছিক। সেট করা হলে, তা অবশ্যই WEB হতে হবে।
    গুগল অ্যানালিটিক্স গন্তব্যে অতিরিক্ত ডেটা উৎস হিসেবে পাঠানো ইভেন্টসমূহ আবশ্যক । নিম্নলিখিতগুলির মধ্যে অন্তত একটি সেট করুন: প্রয়োজনীয় ঐচ্ছিক। সেট করা হলে, তা অবশ্যই WEB হতে হবে।

  3. আপনি যদি কোনো গুগল অ্যাডস ডেস্টিনেশনে অতিরিক্ত ডেটা সোর্স হিসেবে ইভেন্ট পাঠান, তাহলে ‘গুগল কীভাবে অতিরিক্ত ডেটা সোর্সের ডেটা পরিচালনা করে’ তা পর্যালোচনা করুন।

  4. ইভেন্টের জন্য আপনার কাছে মান থাকলে অন্য যেকোনো ফিল্ড পূরণ করুন। উপলব্ধ ফিল্ডগুলির সম্পূর্ণ তালিকার জন্য Event রেফারেন্স ডকুমেন্টেশন দেখুন।

গুগল কীভাবে অতিরিক্ত ডেটা উৎসের ডেটা পরিচালনা করে

একই কনভার্সন অ্যাকশনের মধ্যে, গুগল বিভিন্ন উৎস (যেমন আপনার ওয়েবসাইট ট্যাগ এবং ডেটা ম্যানেজার এপিআই ইনজেশন রিকোয়েস্ট) থেকে পাঠানো কনভার্সন ইভেন্টগুলোর ডুপ্লিকেট বাদ দেওয়ার জন্য transactionId ব্যবহার করে। নিচের সারণিতে ব্যাখ্যা করা হয়েছে যে আপনার ইনজেশন রিকোয়েস্ট থেকে প্রাপ্ত ডেটা কীভাবে প্রসেস করা হয়।

দৃশ্যকল্প ডেটা ক্ষেত্র কীভাবে এটি পরিচালনা করা হয়
transactionId আইডি একটি বিদ্যমান ট্যাগ ইভেন্টের সাথে মেলে conversionValue ( currencyCode সহ)

আপডেট করা হয়েছে। Event থেকে conversionValue ( currencyCode সহ) ট্যাগ দ্বারা রেকর্ড করা মূল মানটিকে ওভাররাইড করে।

দ্রষ্টব্য: কোনো কনভার্সন অ্যাকশনের প্রাথমিক ১৪-দিনের ট্রায়াল পিরিয়ড চলাকালীন, ভ্যালু আপডেট নিষ্ক্রিয় থাকে। ট্রায়াল পিরিয়ড শেষ না হওয়া পর্যন্ত Google Ads রিপোর্টিং-এ ট্যাগটির ভ্যালু ওভাররাইড করা হবে না।

transactionId আইডি একটি বিদ্যমান ট্যাগ ইভেন্টের সাথে মেলে conversionValue বা currencyCode ছাড়া অন্যান্য ফিল্ড (উদাহরণস্বরূপ, adIdentifiers.gclid ) উপেক্ষা করা হয়েছে। আপনার অতিরিক্ত ডেটা উৎসের অন্যান্য ফিল্ড ভ্যালুগুলো, মিলে যাওয়া লেনদেনগুলোর জন্য আপনার গুগল ট্যাগ দ্বারা প্রাথমিকভাবে রেকর্ড করা ফিল্ড ভ্যালুগুলোকে ওভাররাইট করবে না।
transactionId বিদ্যমান কোনো ইভেন্টের সাথে মেলে না। প্রদত্ত সকল ডেটা (উদাহরণস্বরূপ, userData , conversionValue , currencyCode )

একটি নতুন কনভার্সন ইভেন্ট তৈরি করতে ব্যবহৃত হয়। এরপর গুগল আপনার দেওয়া আইডেন্টিফায়ারগুলো (যেমন adIdentifiers.gclid বা userData ) ব্যবহার করে এই নতুন কনভার্সনটিকে একটি অ্যাড ক্লিকের সাথে যুক্ত করার চেষ্টা করবে।

দ্রষ্টব্য: প্রাথমিক ১৪-দিনের ট্রায়াল সময়কালে, এই নতুন তৈরি হওয়া কনভার্সনগুলো আপনার রিপোর্টিং-এ দেখা যাবে, কিন্তু বিডিং-এর জন্য ব্যবহৃত হবে না। ট্রায়াল শেষ হওয়ার পর, এগুলো স্বয়ংক্রিয়ভাবে বিডযোগ্য হয়ে যাবে।

সেশন অ্যাট্রিবিউট যোগ করুন

আপনি যদি লিডদের জন্য অফলাইন কনভার্সন বা এনহ্যান্সড কনভার্সন পাঠান, তাহলে GCLID বা WBRAID-এর মতো অন্যান্য অ্যাড আইডেন্টিফায়ার উপলব্ধ না থাকলে সেশন অ্যাট্রিবিউট যোগ করুন। আপনি অন্যান্য অ্যাড আইডেন্টিফায়ারের পাশাপাশি সেশন অ্যাট্রিবিউটও অন্তর্ভুক্ত করতে পারেন।

সেশন অ্যাট্রিবিউটগুলো আপনার ওয়েবসাইটের সাথে ব্যবহারকারীর মিথস্ক্রিয়া সম্পর্কে আরও প্রাসঙ্গিক তথ্য ও সংকেত প্রদান করে, যা কনভার্সন পরিমাপ, রিপোর্টিং এবং বিডিংয়ের নির্ভুলতা বাড়াতে পারে।

ডেটা ম্যানেজার এপিআই-তে, সেশন অ্যাট্রিবিউট পাঠানোর জন্য আপনি দুটি পদ্ধতি ব্যবহার করতে পারেন:

  1. সুপারিশকৃত: adIdentifiers এর sessionAttributes ফিল্ডটিকে base64 এনকোডেড সেশন অ্যাট্রিবিউট স্ট্রিং-এ সেট করুন। এনকোডেড স্ট্রিংটি ক্যাপচার করার জন্য আপনার ফর্ম সাবমিশন পেজগুলো পরিবর্তন করতে "How to capture session_attributes"- এর নির্দেশাবলী অনুসরণ করুন।

  2. যদি আপনি জাভাস্ক্রিপ্ট ব্যবহার করতে না পারেন, তাহলে স্বতন্ত্র সেশন অ্যাট্রিবিউট ফিল্ডগুলো ক্যাপচার করুন এবং প্রত্যেকটিকে experimentalFields তালিকায় একটি পৃথক ExperimentalField হিসেবে যুক্ত করুন:

    • gad_campaignid
    • session_start_time_usec
    • gad_source
    • landing_page_url
    • landing_page_referrer

    আপনার যদি landing_page_user_agent সেশন অ্যাট্রিবিউটের জন্য কোনো ভ্যালু থাকে, তাহলে সেটি adIdentifiers.landingPageDeviceInfo এর userAgent ফিল্ডে পাঠান।

    স্বতন্ত্র কী-ভ্যালু পেয়ার পাঠানোর ক্ষেত্রে সেরা পদ্ধতিগুলো নিচে দেওয়া হলো:

    • ধারাবাহিকভাবে gad_campaignid এবং session_start_time_usec পাঠান। সঠিক অ্যাট্রিবিউশনের জন্য এই ফিল্ডগুলো অত্যন্ত গুরুত্বপূর্ণ।
    • ভুল বা আংশিক landing_page_url ভ্যালু দেবেন না, যেমন—প্লেসহোল্ডার স্ট্রিং, অ্যাপ্লিকেশনের অভ্যন্তরীণ পাথ বা অসম্পূর্ণ URL। আপনার কাছে সঠিক ও সম্পূর্ণ URL না থাকলে landing_page_url উল্লেখ করবেন না।

    এখানে একটি নমুনা ইভেন্টের অংশবিশেষ দেওয়া হলো, যেখানে experimentalFields এ gad_campaignid ও session_start_time_usec এবং landingPageDeviceInfo ফিল্ডে ইউজার এজেন্ট-এর এন্ট্রি রয়েছে:

    {
  ...,
  "experimentalFields": [
    {
      "field": "gad_campaignid",
      "value": "21288051566"
    },
    {
      "field": "session_start_time_usec",
      "value": "1767711548052000"
    }
  ],
  "adIdentifiers": {
    "landingPageDeviceInfo": {
      "userAgent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/143.0.0.0 Safari/537.36"
    }
  }
}

গুগল অ্যানালিটিক্স তথ্য যোগ করুন

অতিরিক্ত ডেটা উৎস হিসেবে পাঠানো কোনো ইভেন্টের গন্তব্যে যদি গুগল অ্যানালিটিক্স প্রপার্টি অন্তর্ভুক্ত থাকে, তাহলে নির্দেশ অনুযায়ী নিম্নলিখিত ফিল্ডগুলি পূরণ করুন:

eventName

আবশ্যক । গুগল অ্যানালিটিক্স ইভেন্টের নাম।

transactionId

আবশ্যক । ইভেন্টটির অনন্য শনাক্তকারী।

অন্তত একটি শনাক্তকারী

নিম্নলিখিত ক্ষেত্রগুলির মধ্যে অন্তত একটি অবশ্যই সেট করতে হবে:

destinationReferences

অনুরোধ-স্তরের destinations তালিকায় একাধিক Google Analytics Destination থাকলে এটি আবশ্যক । কোন Google Analytics গন্তব্যটি ইভেন্টটি গ্রহণ করবে তা নির্দিষ্ট করতে destinationReferences এ একটি এন্ট্রি যোগ করুন। গন্তব্য রেফারেন্স সম্পর্কে আরও তথ্যের জন্য একাধিক গন্তব্যে ইভেন্ট পাঠানো দেখুন।

যদি destinationReferences সেট করা না থাকে অথবা এতে গুগল অ্যানালিটিক্স ডেস্টিনেশন নির্দেশকারী একাধিক এন্ট্রি থাকে, তাহলে ডেটা ম্যানেজার এপিআই MULTIPLE_DESTINATIONS_FOR_GOOGLE_ANALYTICS_EVENT ত্রুটি সহ ইভেন্টটি প্রত্যাখ্যান করে।

userId

ঐচ্ছিক। ব্যবহারকারীর ইউজার-আইডি ।

additionalEventParameters

ঐচ্ছিক, তবে সুপারিশকৃত। অন্যান্য Event ফিল্ডে অন্তর্ভুক্ত নয় এমন যেকোনো গুগল অ্যানালিটিক্স ইভেন্ট প্যারামিটার দিয়ে এই তালিকাটি পূরণ করুন। প্যারামিটারগুলোর মধ্যে purchase ইভেন্ট থেকে অতিরিক্ত সুপারিশকৃত প্যারামিটার, অথবা আপনার সংগ্রহ করতে চাওয়া অন্য যেকোনো প্যারামিটার অন্তর্ভুক্ত থাকতে পারে। EventParameter এর parameterName এর জন্য গুগল অ্যানালিটিক্স প্যারামিটারের নামটি ব্যবহার করুন।

উদাহরণস্বরূপ, যদি আপনার কাছে কোনো লেনদেনের সাথে যুক্ত কর থাকে, তাহলে additionalEventParameters এ একটি এন্ট্রি যোগ করুন, যেখানে parameterName tax এবং value করের পরিমাণ হিসেবে সেট করা হবে।

আমরা transactionId , currency , বা value গুগল অ্যানালিটিক্স ইভেন্ট প্যারামিটারগুলির জন্য এন্ট্রি যোগ করার পরামর্শ দিই না। এর পরিবর্তে, Event এর ` transactionId , currency , এবং conversionValue পূরণ করুন, যা additionalEventParameters এর যেকোনো এন্ট্রির চেয়ে অগ্রাধিকার পায়।

ক্রয় ইভেন্টের জন্য কার্ট ডেটা যোগ করুন

ক্রয়কৃত আইটেমগুলোর তথ্য দিয়ে Event cartData ফিল্ডটি পূরণ করুন। ক্রয়কৃত প্রতিটি আইটেমের জন্য, CartData এর items তালিকায় একটি Item অবজেক্ট যোগ করুন এবং নির্দেশ অনুযায়ী নিম্নলিখিত ফিল্ডগুলো পূরণ করুন:

itemId
আবশ্যক । আইটেমটির জন্য একটি অনন্য শনাক্তকারী।
unitPrice

আবশ্যক । কর, শিপিং এবং ইভেন্ট-ভিত্তিক (লেনদেন-স্তরের) ছাড় ব্যতীত একক মূল্য।

যদি আইটেমটিতে আইটেম-ভিত্তিক ছাড় থাকে, তাহলে ছাড়-পরবর্তী একক মূল্য ব্যবহার করুন। উদাহরণস্বরূপ, যদি কোনো আইটেমের একক মূল্য 27.67 এবং একক ছাড় 6.66 হয়, তাহলে unitPrice 21.01 নির্ধারণ করুন।

quantity

প্রয়োজনীয় । এই নির্দিষ্ট পণ্যটির জন্য ক্রয়কৃত ইউনিটের পরিমাণ।

additionalItemParameters

এই তালিকাটি এমন যেকোনো আইটেম-স্কোপড প্যারামিটার দিয়ে পূরণ করুন যা অন্যান্য Item ফিল্ডে অন্তর্ভুক্ত নয়। ItemParameter এর parameterName হিসেবে Google Analytics আইটেম প্যারামিটারের নামটি ব্যবহার করুন।

উদাহরণস্বরূপ, যদি আপনার কাছে কোনো আইটেমের ব্র্যান্ড এবং ক্যাটাগরি জানা থাকে, তাহলে আইটেমটির additionalItemParameters এ একটি এন্ট্রি যোগ করুন যেখানে parameterName item_brand এবং value ব্র্যান্ডের নাম হিসেবে সেট করা হবে, এবং আরেকটি এন্ট্রি যোগ করুন যেখানে parameterName item_category এবং value আইটেমটির ক্যাটাগরি হিসেবে সেট করা হবে।

আমরা Google Analytics আইটেম প্যারামিটার ' quantity , ' price বা item_id এর জন্য এন্ট্রি যোগ করার পরামর্শ দিই না। এর পরিবর্তে, Item itemId , unitPrice এবং quantity পূরণ করুন, যা additionalItemParameters এর যেকোনো এন্ট্রির চেয়ে অগ্রাধিকার পায়।

এখানে দ্বিতীয় ইভেন্ট থেকে ফরম্যাট করা, হ্যাশ করা এবং এনকোড করা ডেটার একটি নমুনা Event হলো, সাথে গুগল অ্যানালিটিক্সের জন্য অতিরিক্ত ডেটাও রয়েছে:

{
  "adIdentifiers": {
     "gclid": "GCLID_2"
  },
  "conversionValue": 42.02,
  "currency": "EUR",
  "eventTimestamp": "2025-06-10T23:42:33-05:00",
  "transactionId": "DEF999911111",
  "eventSource": "WEB",
  "userData": {
    "userIdentifiers": [
      {
        "emailAddress": "3E693CF7E5B67880BFF33B2D2626DADB7BF1D4BC737192E47CF8BAA89ACF2250"
      },
      {
        "emailAddress": "223EBDA6F6889B1494551BA902D9D381DAF2F642BAE055888E96343D53E9F9C4"
      },
      {
        "address": {
          "givenName": "2752B88686847FA5C86F47B94CE652B7B3F22A91C37617D451A4DB9AFA431450",
          "familyName": "6654977D57DDDD3C0329CA741B109EF6CD6430BEDD00008AAD213DF25683D77F",
          "regionCode": "PT",
          "postalCode": "1229-076"
        }
      }
    ],
  },
  "userProperties": {
    "customerType": "RETURNING"
  },
  "eventName": "purchase",
  "clientId": "9876543210.1761582117",
  "userId": "user_DEF9876",
  "additionalEventParameters": [
    {
      "parameterName": "ad_unit_name",
      "value": "Banner_02"
    }
  ],
  "cartData": {
    "transactionDiscount": 6.66,
    "items": [
      {
        "itemId": "SKU_12346",
        "quantity": 2,
        "unitPrice": 21.01,
        "additionalItemParameters": [
          {
            "parameterName": "item_name",
            "value": "Google Grey Women's Tee"
          },
          {
            "parameterName": "affiliation",
            "value": "Google Merchandise Store"
          },
          {
            "parameterName": "coupon",
            "value": "SUMMER_FUN"
          },
          {
            "parameterName": "discount",
            "value": "3.33"
          },
          {
            "parameterName": "index",
            "value": "1"
          },
          {
            "parameterName": "item_brand",
            "value": "Google"
          },
          {
            "parameterName": "item_category",
            "value": "Apparel"
          },
          {
            "parameterName": "item_category2",
            "value": "Adult"
          },
          {
            "parameterName": "item_category3",
            "value": "Shirts"
          },
          {
            "parameterName": "item_category4",
            "value": "Crew"
          },
          {
            "parameterName": "item_category5",
            "value": "Short sleeve"
          },
          {
            "parameterName": "item_list_id",
            "value": "related_products"
          },
          {
            "parameterName": "item_list_name",
            "value": "Related Products"
          }
        ]
      }
    ]
  }
}

অনুরোধের মূল অংশ তৈরি করুন

রিকোয়েস্ট বডি তৈরি করতে, destinations এবং events একত্রিত করুন, encoding ফিল্ড সেট করুন, এবং আপনার ইচ্ছামত অন্য যেকোনো রিকোয়েস্ট ফিল্ড, যেমন validateOnly ও consent , যোগ করুন।

এই নির্দেশিকার উদাহরণগুলিতে এনক্রিপশন ব্যবহার করা হয়নি, কিন্তু আপনি আপনার প্রক্রিয়ায় এনক্রিপশন যোগ করতে ‘ব্যবহারকারীর ডেটা এনক্রিপ্ট করুন ’ অংশের নির্দেশাবলী অনুসরণ করতে পারেন।

অনুরোধ পাঠান

আপনার ব্রাউজার থেকে অনুরোধ চেষ্টা করার ধাপগুলো নিচে দেওয়া হলো:

  1. REST ট্যাবটি নির্বাচন করুন এবং একটি নতুন ট্যাব বা উইন্ডোতে API Explorer খোলার জন্য Open in API Explorer-এ ক্লিক করুন।
  2. এপিআই এক্সপ্লোরারে রিকোয়েস্ট বডিতে, REPLACE_WITH দিয়ে শুরু হওয়া প্রতিটি স্ট্রিং, যেমন REPLACE_WITH_OPERATING_ACCOUNT_TYPE , প্রাসঙ্গিক মান দিয়ে প্রতিস্থাপন করুন।
  3. অনুরোধটি পাঠানোর জন্য API Explorer পেজের নিচে থাকা Execute বাটনে ক্লিক করুন এবং অনুমোদনের নির্দেশাবলী পূরণ করুন।
  4. পরিবর্তনগুলো প্রয়োগ না করে অনুরোধটি যাচাই করতে validateOnly কে true সেট করুন। যখন আপনি পরিবর্তনগুলো প্রয়োগ করতে প্রস্তুত হবেন, তখন validateOnly কে false সেট করুন।

আপনি যদি কোনো ক্লায়েন্ট লাইব্রেরি ইনস্টল করে থাকেন , তাহলে কীভাবে একটি অনুরোধ তৈরি ও প্রেরণ করতে হয় তার সম্পূর্ণ কোড নমুনা দেখতে আপনার নির্বাচিত প্রোগ্রামিং ভাষার ট্যাবটি নির্বাচন করুন।

বিশ্রাম

এপিআই এক্সপ্লোরারে খুলুন 
{
    "destinations": [
        {
            "operatingAccount": {
                "accountType": "OPERATING_ACCOUNT_TYPE",
                "accountId": "OPERATING_ACCOUNT_ID"
            },
            "loginAccount": {
                "accountType": "LOGIN_ACCOUNT_TYPE",
                "accountId": "LOGIN_ACCOUNT_ID"
            },
            "productDestinationId": "CONVERSION_ACTION_ID"
        }
    ],
    "encoding": "HEX",
    "events": [
        {
            "adIdentifiers": {
                "gclid": "GCLID_1"
            },
            "conversionValue": 30.03,
            "currency": "USD",
            "eventTimestamp": "2025-06-10T20:07:01Z",
            "transactionId": "ABC798654321",
            "eventSource": "WEB",
            "userData": {
                "userIdentifiers": [
                    {
                        "address": {
                            "givenName": "96D9632F363564CC3032521409CF22A852F2032EEC099ED5967C0D000CEC607A",
                            "familyName": "DB98D2607EFFFA28AFF66975868BF54C075ECA7157E35064DCE08E20B85B1081",
                            "regionCode": "US",
                            "postalCode": "94045"
                        }
                    }
                ]
            },
            "userProperties": {
                "customerType": "NEW",
                "customerValueBucket": "HIGH"
            },
            "eventName": "purchase",
            "clientId": "1234567890.1761581763",
            "userId": "user_ABC12345",
            "additionalEventParameters": [
                {
                    "parameterName": "ad_unit_name",
                    "value": "Banner_01"
                }
            ],
            "cartData": {
                "transactionDiscount": 6.66,
                "items": [
                    {
                        "itemId": "SKU_12345",
                        "quantity": 3,
                        "unitPrice": 10.01,
                        "additionalItemParameters": [
                            {
                                "parameterName": "item_name",
                                "value": "Stan and Friends Tee"
                            },
                            {
                                "parameterName": "affiliation",
                                "value": "Google Merchandise Store"
                            },
                            {
                                "parameterName": "coupon",
                                "value": "SUMMER_FUN"
                            },
                            {
                                "parameterName": "discount",
                                "value": "2.22"
                            },
                            {
                                "parameterName": "index",
                                "value": "0"
                            },
                            {
                                "parameterName": "item_brand",
                                "value": "Google"
                            },
                            {
                                "parameterName": "item_category",
                                "value": "Apparel"
                            },
                            {
                                "parameterName": "item_category2",
                                "value": "Adult"
                            },
                            {
                                "parameterName": "item_category3",
                                "value": "Shirts"
                            },
                            {
                                "parameterName": "item_category4",
                                "value": "Crew"
                            },
                            {
                                "parameterName": "item_category5",
                                "value": "Short sleeve"
                            },
                            {
                                "parameterName": "item_list_id",
                                "value": "related_products"
                            },
                            {
                                "parameterName": "item_list_name",
                                "value": "Related Products"
                            }
                        ]
                    }
                ]
            }
        },
        {
            "adIdentifiers": {
                "gclid": "GCLID_2"
            },
            "conversionValue": 42.02,
            "currency": "EUR",
            "eventTimestamp": "2025-06-11T04:42:33Z",
            "transactionId": "DEF999911111",
            "eventSource": "WEB",
            "userData": {
                "userIdentifiers": [
                    {
                        "emailAddress": "3E693CF7E5B67880BFF33B2D2626DADB7BF1D4BC737192E47CF8BAA89ACF2250"
                    },
                    {
                        "emailAddress": "223EBDA6F6889B1494551BA902D9D381DAF2F642BAE055888E96343D53E9F9C4"
                    },
                    {
                        "address": {
                            "givenName": "2752B88686847FA5C86F47B94CE652B7B3F22A91C37617D451A4DB9AFA431450",
                            "familyName": "6654977D57DDDD3C0329CA741B109EF6CD6430BEDD00008AAD213DF25683D77F",
                            "regionCode": "PT",
                            "postalCode": "1229-076"
                        }
                    }
                ]
            },
            "userProperties": {
                "customerType": "RETURNING"
            },
            "eventName": "purchase",
            "clientId": "9876543210.1761582117",
            "userId": "user_DEF9876",
            "additionalEventParameters": [
                {
                    "parameterName": "ad_unit_name",
                    "value": "Banner_02"
                }
            ],
            "cartData": {
                "transactionDiscount": 6.66,
                "items": [
                    {
                        "itemId": "SKU_12346",
                        "quantity": 2,
                        "unitPrice": 21.01,
                        "additionalItemParameters": [
                            {
                                "parameterName": "item_name",
                                "value": "Google Grey Women's Tee"
                            },
                            {
                                "parameterName": "affiliation",
                                "value": "Google Merchandise Store"
                            },
                            {
                                "parameterName": "coupon",
                                "value": "SUMMER_FUN"
                            },
                            {
                                "parameterName": "discount",
                                "value": "3.33"
                            },
                            {
                                "parameterName": "index",
                                "value": "1"
                            },
                            {
                                "parameterName": "item_brand",
                                "value": "Google"
                            },
                            {
                                "parameterName": "item_category",
                                "value": "Apparel"
                            },
                            {
                                "parameterName": "item_category2",
                                "value": "Adult"
                            },
                            {
                                "parameterName": "item_category3",
                                "value": "Shirts"
                            },
                            {
                                "parameterName": "item_category4",
                                "value": "Crew"
                            },
                            {
                                "parameterName": "item_category5",
                                "value": "Short sleeve"
                            },
                            {
                                "parameterName": "item_list_id",
                                "value": "related_products"
                            },
                            {
                                "parameterName": "item_list_name",
                                "value": "Related Products"
                            }
                        ]
                    }
                ]
            }
        }
    ],
    "validateOnly": true
}

.NET 

// Copyright 2025 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// 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;
using Google.Protobuf.WellKnownTypes;
using static Google.Ads.DataManager.V1.ProductAccount.Types;

namespace Google.Ads.DataManager.Samples
{
    // <summary>
    // Sends an <see cref="IngestEventsRequest" /> without using encryption.
    //
    // Event data is read from a data file. See the <c>events_1.json</c> file in the
    // <c>sampledata</c> directory for an example.
    // </summary>
    public class IngestEvents
    {
        private static readonly int MaxEventsPerRequest = 2_000;

        [Verb("ingest-events", HelpText = "Sends an IngestEventsRequest without using encryption.")]
        public class Options
        {
            [Option(
                "operatingAccountType",
                Required = true,
                HelpText = "Account type of the operating account"
            )]
            public AccountType OperatingAccountType { get; set; }

            [Option(
                "operatingAccountId",
                Required = true,
                HelpText = "ID of the operating account"
            )]
            public string OperatingAccountId { get; set; } = null!;

            [Option(
                "loginAccountType",
                Required = false,
                HelpText = "Account type of the login account"
            )]
            public AccountType? LoginAccountType { get; set; }

            [Option("loginAccountId", Required = false, HelpText = "ID of the login account")]
            public string? LoginAccountId { get; set; }

            [Option(
                "linkedAccountProduct",
                Required = false,
                HelpText = "Account type of the linked account"
            )]
            public AccountType? LinkedAccountType { get; set; }

            [Option("linkedAccountId", Required = false, HelpText = "ID of the linked account")]
            public string? LinkedAccountId { get; set; }

            [Option(
                "conversionActionId",
                Required = true,
                HelpText = "ID of the conversion action"
            )]
            public string ConversionActionId { get; set; } = null!;

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

            [Option(
                "validateOnly",
                Default = true,
                HelpText = "Whether to enable validateOnly on the request"
            )]
            public bool ValidateOnly { get; set; }
        }

        public void Run(Options options)
        {
            RunExample(
                options.OperatingAccountType,
                options.OperatingAccountId,
                options.LoginAccountType,
                options.LoginAccountId,
                options.LinkedAccountType,
                options.LinkedAccountId,
                options.ConversionActionId,
                options.JsonFile,
                options.ValidateOnly
            );
        }

        private void RunExample(
            AccountType operatingAccountType,
            string operatingAccountId,
            AccountType? loginAccountType,
            string? loginAccountId,
            AccountType? linkedAccountType,
            string? linkedAccountId,
            string conversionActionId,
            string jsonFile,
            bool validateOnly
        )
        {
            if (loginAccountId == null ^ loginAccountType == null)
            {
                throw new ArgumentException(
                    "Must specify either both or neither of login account ID and login account "
                        + "type"
                );
            }
            if (linkedAccountId == null ^ linkedAccountType == null)
            {
                throw new ArgumentException(
                    "Must specify either both or neither of linked account ID and linked account "
                        + "type"
                );
            }

            // Reads member data from the data file.
            List<EventRecord> eventRecords = ReadEventData(jsonFile);
            // Gets an instance of the UserDataFormatter for normalizing and formatting the data.
            UserDataFormatter userDataFormatter = new UserDataFormatter();

            // Builds the events collection for the request.
            var events = new List<Event>();
            foreach (var eventRecord in eventRecords)
            {
                var eventBuilder = new Event();

                try
                {
                    eventBuilder.EventTimestamp = Timestamp.FromDateTime(
                        DateTime.Parse(eventRecord.Timestamp ?? "").ToUniversalTime()
                    );
                }
                catch (FormatException)
                {
                    Console.WriteLine(
                        $"Skipping event with invalid timestamp: {eventRecord.Timestamp}"
                    );
                    continue;
                }

                if (string.IsNullOrEmpty(eventRecord.TransactionId))
                {
                    Console.WriteLine("Skipping event with no transaction ID");
                    continue;
                }
                eventBuilder.TransactionId = eventRecord.TransactionId;

                if (!string.IsNullOrEmpty(eventRecord.EventSource))
                {
                    if (
                        System.Enum.TryParse(
                            eventRecord.EventSource,
                            true,
                            out EventSource eventSource
                        )
                    )
                    {
                        eventBuilder.EventSource = eventSource;
                    }
                    else
                    {
                        Console.WriteLine(
                            $"Skipping event with invalid event source: {eventRecord.EventSource}"
                        );
                        continue;
                    }
                }

                if (!string.IsNullOrEmpty(eventRecord.Gclid))
                {
                    eventBuilder.AdIdentifiers = new AdIdentifiers { Gclid = eventRecord.Gclid };
                }

                if (!string.IsNullOrEmpty(eventRecord.Currency))
                {
                    eventBuilder.Currency = eventRecord.Currency;
                }

                if (eventRecord.Value.HasValue)
                {
                    eventBuilder.ConversionValue = eventRecord.Value.Value;
                }

                var userDataBuilder = new UserData();

                // Adds a UserIdentifier for each valid email address for the eventRecord.
                if (eventRecord.Emails != null)
                {
                    foreach (var email in eventRecord.Emails)
                    {
                        try
                        {
                            string preparedEmail = userDataFormatter.ProcessEmailAddress(
                                email,
                                UserDataFormatter.Encoding.Hex
                            );
                            // Adds an email address identifier with the encoded email hash.
                            userDataBuilder.UserIdentifiers.Add(
                                new UserIdentifier { EmailAddress = preparedEmail }
                            );
                        }
                        catch (ArgumentException)
                        {
                            // Skips invalid input.
                            continue;
                        }
                    }
                }

                // Adds a UserIdentifier for each valid phone number for the eventRecord.
                if (eventRecord.PhoneNumbers != null)
                {
                    foreach (var phoneNumber in eventRecord.PhoneNumbers)
                    {
                        try
                        {
                            string preparedPhoneNumber = userDataFormatter.ProcessPhoneNumber(
                                phoneNumber,
                                UserDataFormatter.Encoding.Hex
                            );
                            // Adds a phone number identifier with the encoded phone hash.
                            userDataBuilder.UserIdentifiers.Add(
                                new UserIdentifier { PhoneNumber = preparedPhoneNumber }
                            );
                        }
                        catch (ArgumentException)
                        {
                            // Skips invalid input.
                            continue;
                        }
                    }
                }

                if (userDataBuilder.UserIdentifiers.Any())
                {
                    eventBuilder.UserData = userDataBuilder;
                }
                events.Add(eventBuilder);
            }

            // Builds the Destination for the request.
            var destinationBuilder = new Destination
            {
                OperatingAccount = new ProductAccount
                {
                    AccountType = operatingAccountType,
                    AccountId = operatingAccountId,
                },
                ProductDestinationId = conversionActionId,
            };

            if (loginAccountType.HasValue && loginAccountId != null)
            {
                destinationBuilder.LoginAccount = new ProductAccount
                {
                    AccountType = loginAccountType.Value,
                    AccountId = loginAccountId,
                };
            }

            if (linkedAccountType.HasValue && linkedAccountId != null)
            {
                destinationBuilder.LinkedAccount = new ProductAccount
                {
                    AccountType = linkedAccountType.Value,
                    AccountId = linkedAccountId,
                };
            }

            IngestionServiceClient ingestionServiceClient = IngestionServiceClient.Create();

            int requestCount = 0;

            // Batches requests to send up to the maximum number of events per request.
            for (var i = 0; i < events.Count; i += MaxEventsPerRequest)
            {
                IEnumerable<Event> batch = events.Skip(i).Take(MaxEventsPerRequest);
                requestCount++;
                var request = new IngestEventsRequest
                {
                    Destinations = { destinationBuilder },
                    // Adds events from the current batch.
                    Events = { batch },
                    Consent = new Consent
                    {
                        AdPersonalization = ConsentStatus.ConsentGranted,
                        AdUserData = ConsentStatus.ConsentGranted,
                    },
                    // Sets validate_only. If true, then the Data Manager API only validates the
                    // request but doesn't apply changes.
                    ValidateOnly = validateOnly,
                    Encoding = V1.Encoding.Hex,
                };

                // Sends the data to the Data Manager API.
                IngestEventsResponse response = ingestionServiceClient.IngestEvents(request);
                Console.WriteLine($"Response for request #{requestCount}:\n{response}");
            }
            Console.WriteLine($"# of requests sent: {requestCount}");
        }

        private class EventRecord
        {
            public List<string>? Emails { get; set; }
            public List<string>? PhoneNumbers { get; set; }
            public string? Timestamp { get; set; }
            public string? TransactionId { get; set; }
            public string? EventSource { get; set; }
            public double? Value { get; set; }
            public string? Currency { get; set; }
            public string? Gclid { get; set; }
        }

        private List<EventRecord> ReadEventData(string jsonFile)
        {
            string jsonString = File.ReadAllText(jsonFile);
            var options = new JsonSerializerOptions { PropertyNameCaseInsensitive = true };
            return JsonSerializer.Deserialize<List<EventRecord>>(jsonString, options)
                ?? new List<EventRecord>();
        }
    }
}

IngestEvents.cs

জাভা 

// Copyright 2025 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package com.google.ads.datamanager.samples;

import com.beust.jcommander.Parameter;
import com.google.ads.datamanager.samples.common.BaseParamsConfig;
import com.google.ads.datamanager.util.UserDataFormatter;
import com.google.ads.datamanager.util.UserDataFormatter.Encoding;
import com.google.ads.datamanager.v1.AdIdentifiers;
import com.google.ads.datamanager.v1.Consent;
import com.google.ads.datamanager.v1.ConsentStatus;
import com.google.ads.datamanager.v1.Destination;
import com.google.ads.datamanager.v1.Event;
import com.google.ads.datamanager.v1.EventSource;
import com.google.ads.datamanager.v1.IngestEventsRequest;
import com.google.ads.datamanager.v1.IngestEventsResponse;
import com.google.ads.datamanager.v1.IngestionServiceClient;
import com.google.ads.datamanager.v1.ProductAccount;
import com.google.ads.datamanager.v1.ProductAccount.AccountType;
import com.google.ads.datamanager.v1.UserData;
import com.google.ads.datamanager.v1.UserIdentifier;
import com.google.common.base.Strings;
import com.google.common.collect.Lists;
import com.google.common.reflect.TypeToken;
import com.google.gson.GsonBuilder;
import com.google.protobuf.util.Timestamps;
import java.io.BufferedReader;
import java.io.IOException;
import java.lang.reflect.Type;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.text.ParseException;
import java.util.ArrayList;
import java.util.List;
import java.util.logging.Logger;

/**
 * Sends an {@link IngestEventsRequest} without using encryption.
 *
 * <p>Event data is read from a data file. See the {@code events_1.json} file in the {@code
 * resources/sampledata} directory for a sample file.
 */
public class IngestEvents {
  private static final Logger LOGGER = Logger.getLogger(IngestEvents.class.getName());

  /** The maximum number of events allowed per request. */
  private static final int MAX_EVENTS_PER_REQUEST = 2_000;

  private static final class ParamsConfig extends BaseParamsConfig<ParamsConfig> {

    @Parameter(
        names = "--operatingAccountType",
        required = true,
        description = "Account type of the operating account")
    AccountType operatingAccountType;

    @Parameter(
        names = "--operatingAccountId",
        required = true,
        description = "ID of the operating account")
    String operatingAccountId;

    @Parameter(
        names = "--loginAccountType",
        required = false,
        description = "Account type of the login account")
    AccountType loginAccountType;

    @Parameter(
        names = "--loginAccountId",
        required = false,
        description = "ID of the login account")
    String loginAccountId;

    @Parameter(
        names = "--linkedAccountType",
        required = false,
        description = "Account type of the linked account")
    AccountType linkedAccountType;

    @Parameter(
        names = "--linkedAccountId",
        required = false,
        description = "ID of the linked account")
    String linkedAccountId;

    @Parameter(
        names = "--conversionActionId",
        required = true,
        description = "ID of the conversion action")
    String conversionActionId;

    @Parameter(
        names = "--jsonFile",
        required = true,
        description = "JSON file containing user data to ingest")
    String jsonFile;

    @Parameter(
        names = "--validateOnly",
        required = false,
        arity = 1,
        description = "Whether to enable validateOnly on the request")
    boolean validateOnly = true;
  }

  public static void main(String[] args) throws IOException {
    ParamsConfig paramsConfig = new ParamsConfig().parseOrExit(args);
    if ((paramsConfig.loginAccountId == null) != (paramsConfig.loginAccountType == null)) {
      throw new IllegalArgumentException(
          "Must specify either both or neither of login account ID and login account type");
    }
    if ((paramsConfig.linkedAccountId == null) != (paramsConfig.linkedAccountType == null)) {
      throw new IllegalArgumentException(
          "Must specify either both or neither of linked account ID and linked account type");
    }
    new IngestEvents().runExample(paramsConfig);
  }

  /**
   * Runs the example. This sample assumes that the login and operating account are the same.
   *
   * @param params the parameters for the example
   */
  private void runExample(ParamsConfig params) throws IOException {
    // Reads event data from the JSON file.
    List<EventRecord> eventRecords = readEventData(params.jsonFile);

    // Gets an instance of the UserDataFormatter for normalizing and formatting the data.
    UserDataFormatter userDataFormatter = UserDataFormatter.create();

    // Builds the events collection for the request.
    List<Event> events = new ArrayList<>();
    for (EventRecord eventRecord : eventRecords) {
      Event.Builder eventBuilder = Event.newBuilder();
      try {
        eventBuilder.setEventTimestamp(Timestamps.parse(eventRecord.timestamp));
      } catch (ParseException pe) {
        LOGGER.warning(
            () ->
                String.format("Skipping event with invalid timestamp: %s", eventRecord.timestamp));
        continue;
      }

      if (Strings.isNullOrEmpty(eventRecord.transactionId)) {
        LOGGER.warning("Skipping event with no transaction ID");
        continue;
      }
      eventBuilder.setTransactionId(eventRecord.transactionId);
      if (!Strings.isNullOrEmpty(eventRecord.eventSource)) {
        try {
          eventBuilder.setEventSource(EventSource.valueOf(eventRecord.eventSource));
        } catch (IllegalArgumentException iae) {
          LOGGER.warning("Skipping event with invalid event source: " + eventRecord.eventSource);
          continue;
        }
      }

      if (!Strings.isNullOrEmpty(eventRecord.gclid)) {
        eventBuilder.setAdIdentifiers(AdIdentifiers.newBuilder().setGclid(eventRecord.gclid));
      }

      if (!Strings.isNullOrEmpty(eventRecord.currency)) {
        eventBuilder.setCurrency(eventRecord.currency);
      }

      if (eventRecord.value != null) {
        eventBuilder.setConversionValue(eventRecord.value);
      }

      UserData.Builder userDataBuilder = UserData.newBuilder();

      // Adds a UserIdentifier for each valid email address for the eventRecord.
      if (eventRecord.emails != null) {
        for (String email : eventRecord.emails) {
          String preparedEmail;
          try {
            preparedEmail = userDataFormatter.processEmailAddress(email, Encoding.HEX);
          } catch (IllegalArgumentException iae) {
            // Skips invalid input.
            continue;
          }
          // Sets the email address identifier to the encoded email hash.
          userDataBuilder.addUserIdentifiers(
              UserIdentifier.newBuilder().setEmailAddress(preparedEmail));
        }
      }

      // Adds a UserIdentifier for each valid phone number for the eventRecord.
      if (eventRecord.phoneNumbers != null) {
        for (String phoneNumber : eventRecord.phoneNumbers) {
          String preparedPhoneNumber;
          try {
            preparedPhoneNumber = userDataFormatter.processPhoneNumber(phoneNumber, Encoding.HEX);
          } catch (IllegalArgumentException iae) {
            // Skips invalid input.
            continue;
          }
          // Sets the phone number identifier to the encoded phone number hash.
          userDataBuilder.addUserIdentifiers(
              UserIdentifier.newBuilder().setPhoneNumber(preparedPhoneNumber));
        }
      }

      if (userDataBuilder.getUserIdentifiersCount() > 0) {
        eventBuilder.setUserData(userDataBuilder);
      }
      events.add(eventBuilder.build());
    }

    // Builds the Destination for the request.
    Destination.Builder destinationBuilder =
        Destination.newBuilder()
            .setOperatingAccount(
                ProductAccount.newBuilder()
                    .setAccountType(params.operatingAccountType)
                    .setAccountId(params.operatingAccountId))
            .setProductDestinationId(params.conversionActionId);
    if (params.loginAccountType != null && params.loginAccountId != null) {
      destinationBuilder.setLoginAccount(
          ProductAccount.newBuilder()
              .setAccountType(params.loginAccountType)
              .setAccountId(params.loginAccountId));
    }
    if (params.linkedAccountType != null && params.linkedAccountId != null) {
      destinationBuilder.setLinkedAccount(
          ProductAccount.newBuilder()
              .setAccountType(params.linkedAccountType)
              .setAccountId(params.linkedAccountId));
    }

    try (IngestionServiceClient ingestionServiceClient = IngestionServiceClient.create()) {
      int requestCount = 0;
      // Batches requests to send up to the maximum number of events per request.
      for (List<Event> eventsBatch : Lists.partition(events, MAX_EVENTS_PER_REQUEST)) {
        requestCount++;
        // Builds the request.
        IngestEventsRequest request =
            IngestEventsRequest.newBuilder()
                .addDestinations(destinationBuilder)
                // Adds events from the current batch.
                .addAllEvents(eventsBatch)
                .setConsent(
                    Consent.newBuilder()
                        .setAdPersonalization(ConsentStatus.CONSENT_GRANTED)
                        .setAdUserData(ConsentStatus.CONSENT_GRANTED))
                // Sets validate_only. If true, then the Data Manager API only validates the request
                // but doesn't apply changes.
                .setValidateOnly(params.validateOnly)
                // Sets encoding to match the encoding used.
                .setEncoding(com.google.ads.datamanager.v1.Encoding.HEX)
                .build();

        LOGGER.info(() -> String.format("Request:%n%s", request));
        IngestEventsResponse response = ingestionServiceClient.ingestEvents(request);
        LOGGER.info(String.format("Response for request #:%n%s", requestCount, response));
      }

      LOGGER.info("# of requests sent: " + requestCount);
    }
  }

  /** Data object for a single row of input data. */
  @SuppressWarnings("unused")
  private static class EventRecord {
    private List<String> emails;
    private List<String> phoneNumbers;
    private String timestamp;
    private String transactionId;
    private String eventSource;
    private Double value;
    private String currency;
    private String gclid;
  }

  /** Reads the data file and parses each line into a {@link EventRecord} object. */
  private List<EventRecord> readEventData(String jsonFile) throws IOException {
    try (BufferedReader jsonReader =
        Files.newBufferedReader(Paths.get(jsonFile), StandardCharsets.UTF_8)) {
      // Define the type for Gson to deserialize into (List of EventRecord objects)
      Type recordListType = new TypeToken<ArrayList<EventRecord>>() {}.getType();

      // Parse the JSON string from the file into a List of EventRecord objects
      return new GsonBuilder().create().fromJson(jsonReader, recordListType);
    }
  }
}

IngestEvents.java

নোড 

#!/usr/bin/env node
// Copyright 2025 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     https://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

'use strict';

import {IngestionServiceClient} from '@google-ads/datamanager';
import {protos} from '@google-ads/datamanager';
const {
  Event: DataManagerEvent,
  Destination,
  Encoding: DataManagerEncoding,
  EventSource,
  Consent,
  ConsentStatus,
  IngestEventsRequest,
  ProductAccount,
  UserData,
  UserIdentifier,
} = protos.google.ads.datamanager.v1;
import {UserDataFormatter, Encoding} from '@google-ads/data-manager-util';
import * as fs from 'fs';
import * as yargs from 'yargs';

const MAX_EVENTS_PER_REQUEST = 10000;

interface Arguments {
  operating_account_type: string;
  operating_account_id: string;
  conversion_action_id: string;
  json_file: string;
  validate_only: boolean;
  login_account_type?: string;
  login_account_id?: string;
  linked_account_type?: string;
  linked_account_id?: string;
  [x: string]: unknown;
}

interface EventRow {
  timestamp: string;
  transactionId: string;
  eventSource?: string;
  gclid?: string;
  currency?: string;
  value?: number;
  emails?: string[];
  phoneNumbers?: string[];
}

/**
 * The main function for the IngestEvents sample.
 */
async function main() {
  const argv: Arguments = yargs
    .option('operating_account_type', {
      describe: 'The account type of the operating account.',
      type: 'string',
      required: true,
    })
    .option('operating_account_id', {
      describe: 'The ID of the operating account.',
      type: 'string',
      required: true,
    })
    .option('conversion_action_id', {
      describe: 'The ID of the conversion action.',
      type: 'string',
      required: true,
    })
    .option('json_file', {
      describe: 'JSON file containing user data to ingest.',
      type: 'string',
      required: true,
    })
    .option('validate_only', {
      describe: 'Whether to enable validate_only on the request.',
      type: 'boolean',
      default: true,
    })
    .option('login_account_type', {
      describe: 'The account type of the login account.',
      type: 'string',
    })
    .option('login_account_id', {
      describe: 'The ID of the login account.',
      type: 'string',
    })
    .option('linked_account_type', {
      describe: 'The account type of the linked account.',
      type: 'string',
    })
    .option('linked_account_id', {
      describe: 'The ID of the linked account.',
      type: 'string',
    })
    .option('config', {
      describe: 'Path to a JSON file with arguments.',
      type: 'string',
    })
    .config('config')
    .check((args: Arguments) => {
      if (
        (args.login_account_type && !args.login_account_id) ||
        (!args.login_account_type && args.login_account_id)
      ) {
        throw new Error(
          'Must specify either both or neither of login account type ' +
            'and login account ID',
        );
      }
      if (
        (args.linked_account_type && !args.linked_account_id) ||
        (!args.linked_account_type && args.linked_account_id)
      ) {
        throw new Error(
          'Must specify either both or neither of linked account type ' +
            'and linked account ID',
        );
      }
      return true;
    })
    .parseSync();

  // Reads event data from the JSON file.
  const eventRows: EventRow[] = readEventDataFile(argv.json_file);

  // Builds the events collection for the request.
  const events = [];
  const formatter = new UserDataFormatter();
  for (const eventRow of eventRows) {
    const event = DataManagerEvent.create();
    try {
      const date = new Date(eventRow.timestamp);
      event.eventTimestamp = {
        seconds: Math.floor(date.getTime() / 1000),
        nanos: (date.getTime() % 1000) * 1e6,
      };
    } catch (e) {
      console.warn(
        `Invalid timestamp format: ${eventRow.timestamp}. Skipping row.`,
      );
      continue;
    }

    if (!eventRow.transactionId) {
      console.warn('Skipping event with no transaction ID');
      continue;
    }
    event.transactionId = eventRow.transactionId;

    if (eventRow.eventSource) {
      const eventSourceEnumValue: number | undefined =
        EventSource[eventRow.eventSource as keyof typeof EventSource];
      if (eventSourceEnumValue === undefined) {
        console.warn(
          `Skipping event with invalid event_source: ${eventRow.eventSource}`,
        );
        continue;
      }
      event.eventSource = eventSourceEnumValue;
    }

    if (eventRow.gclid) {
      event.adIdentifiers = {gclid: eventRow.gclid};
    }

    if (eventRow.currency) {
      event.currency = eventRow.currency;
    }

    if (eventRow.value) {
      event.conversionValue = eventRow.value;
    }

    const userData = UserData.create();
    // Adds a UserIdentifier for each valid email address for the eventRecord.
    if (eventRow.emails) {
      for (const email of eventRow.emails) {
        try {
          const processedEmail = formatter.processEmailAddress(
            email,
            Encoding.HEX,
          );
          userData.userIdentifiers.push(
            UserIdentifier.create({emailAddress: processedEmail}),
          );
        } catch (e) {
          console.warn(`Invalid email address: ${email}. Skipping.`);
        }
      }
    }

    // Adds a UserIdentifier for each valid phone number for the eventRecord.
    if (eventRow.phoneNumbers) {
      for (const phoneNumber of eventRow.phoneNumbers) {
        try {
          const processedPhone = formatter.processPhoneNumber(
            phoneNumber,
            Encoding.HEX,
          );
          userData.userIdentifiers.push(
            UserIdentifier.create({phoneNumber: processedPhone}),
          );
        } catch (e) {
          console.warn(`Invalid phone: ${phoneNumber}. Skipping.`);
        }
      }
    }

    if (userData.userIdentifiers.length > 0) {
      event.userData = userData;
    }

    events.push(event);
  }

  // Sets up the Destination.
  const operatingAccountType = convertToAccountType(
    argv.operating_account_type,
    'operating_account_type',
  );

  const destination = Destination.create({
    operatingAccount: ProductAccount.create({
      accountType: operatingAccountType,
      accountId: argv.operating_account_id,
    }),
    productDestinationId: argv.conversion_action_id,
  });

  // The login account is optional.
  if (argv.login_account_type) {
    const loginAccountType = convertToAccountType(
      argv.login_account_type,
      'login_account_type',
    );
    destination.loginAccount = ProductAccount.create({
      accountType: loginAccountType,
      accountId: argv.login_account_id,
    });
  }

  // The linked account is optional.
  if (argv.linked_account_type) {
    const linkedAccountType = convertToAccountType(
      argv.linked_account_type,
      'linked_account_type',
    );
    destination.linkedAccount = ProductAccount.create({
      accountType: linkedAccountType,
      accountId: argv.linked_account_id,
    });
  }

  const client = new IngestionServiceClient();

  let requestCount = 0;
  // Batches requests to send up to the maximum number of events per request.
  for (let i = 0; i < events.length; i += MAX_EVENTS_PER_REQUEST) {
    requestCount++;
    const eventsBatch = events.slice(i, i + MAX_EVENTS_PER_REQUEST);

    // Builds the request.
    const request = IngestEventsRequest.create({
      destinations: [destination],
      // Adds events from the current batch.
      events: eventsBatch,
      consent: Consent.create({
        adUserData: ConsentStatus.CONSENT_GRANTED,
        adPersonalization: ConsentStatus.CONSENT_GRANTED,
      }),
      // Sets encoding to match the encoding used.
      encoding: DataManagerEncoding.HEX,
      // Sets validate_only. If true, then the Data Manager API only validates the request
      validateOnly: argv.validate_only,
    });

    const [response] = await client.ingestEvents(request);
    console.log(`Response for request #${requestCount}:\n`, response);
  }
  console.log(`# of requests sent: ${requestCount}`);
}

/**
 * Reads the event data from the given JSON file.
 * @param {string} jsonFile The path to the JSON file.
 * @return {EventRow[]} An array of event data.
 */
function readEventDataFile(jsonFile: string): EventRow[] {
  const fileContent = fs.readFileSync(jsonFile, 'utf8');
  return JSON.parse(fileContent);
}

/**
 * Validates that a given string is an enum value for the AccountType enum, and
 * if validation passes, returns the AccountType enum value.
 * @param proposedValue the name of an AccountType enum value
 * @param paramName the name of the parameter to use in the error message if validation fails
 * @returns {protos.google.ads.datamanager.v1.ProductAccount.AccountType} The corresponding enum value.
 * @throws {Error} If the string is not an AccountType enum value.
 */
function convertToAccountType(
  proposedValue: string,
  paramName: string,
): protos.google.ads.datamanager.v1.ProductAccount.AccountType {
  const AccountType = ProductAccount.AccountType;
  const accountTypeEnumNames = Object.keys(AccountType).filter(key =>
    isNaN(Number(key)),
  );
  if (!accountTypeEnumNames.includes(proposedValue)) {
    throw new Error(`Invalid ${paramName}: ${proposedValue}`);
  }
  return AccountType[proposedValue as keyof typeof AccountType];
}

if (require.main === module) {
  main().catch(console.error);
}

ingest_events.ts

পিএইচপি 

<?php
// Copyright 2025 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     https://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

/**
 * Sample of sending an IngestEventsRequest without encryption.
 */

require_once dirname(__DIR__, 1) . '/vendor/autoload.php';

use Google\Ads\DataManager\V1\AdIdentifiers;
use Google\Ads\DataManager\V1\Client\IngestionServiceClient;
use Google\Ads\DataManager\V1\Consent;
use Google\Ads\DataManager\V1\ConsentStatus;
use Google\Ads\DataManager\V1\Destination;
use Google\Ads\DataManager\V1\Encoding as DataManagerEncoding;
use Google\Ads\DataManager\V1\Event;
use Google\Ads\DataManager\V1\EventSource;
use Google\Ads\DataManager\V1\IngestEventsRequest;
use Google\Ads\DataManager\V1\ProductAccount;
use Google\Ads\DataManager\V1\ProductAccount\AccountType;
use Google\Ads\DataManager\V1\UserData;
use Google\Ads\DataManager\V1\UserIdentifier;
use Google\Ads\DataManagerUtil\Encoding;
use Google\Ads\DataManagerUtil\Formatter;
use Google\ApiCore\ApiException;
use Google\Protobuf\Timestamp;

// The maximum number of events allowed per request.
const MAX_EVENTS_PER_REQUEST = 2000;

/**
 * Reads the JSON-formatted event data file.
 *
 * @param string $jsonFile The event data file.
 * @return array A list of associative arrays, each representing an event.
 */
function readEventDataFile(string $jsonFile): array
{
    $jsonContent = file_get_contents($jsonFile);
    if ($jsonContent === false) {
        throw new \RuntimeException(sprintf('Could not read JSON file: %s', $jsonFile));
    }
    $events = json_decode($jsonContent, true);
    if (json_last_error() !== JSON_ERROR_NONE) {
        throw new \RuntimeException(sprintf('Invalid JSON in file: %s', $jsonFile));
    }
    return $events;
}

/**
 * Runs the sample.
 *
 * @param int $operatingAccountType The account type of the operating account.
 * @param string $operatingAccountId The ID of the operating account.
 * @param string $conversionActionId The ID of the conversion action.
 * @param string $jsonFile The JSON file containing event data.
 * @param bool $validateOnly Whether to enable validateOnly on the request.
 * @param int|null $loginAccountType The account type of the login account.
 * @param string|null $loginAccountId The ID of the login account.
 * @param int|null $linkedAccountType The account type of the linked account.
 * @param string|null $linkedAccountId The ID of the linked account.
 */
function main(
    int $operatingAccountType,
    string $operatingAccountId,
    string $conversionActionId,
    string $jsonFile,
    bool $validateOnly,
    ?int $loginAccountType = null,
    ?string $loginAccountId = null,
    ?int $linkedAccountType = null,
    ?string $linkedAccountId = null
): void {
    // Reads event data from the data file.
    $eventRecords = readEventDataFile($jsonFile);

    // Gets an instance of the UserDataFormatter for normalizing and formatting the data.
    $formatter = new Formatter();

    // Builds the events collection for the request.
    $events = [];
    foreach ($eventRecords as $eventRecord) {
        $event = new Event();

        if (empty($eventRecord['timestamp'])) {
            error_log('Skipping event with no timestamp.');
            continue;
        }
        try {
            $dateTime = new DateTime($eventRecord['timestamp']);
            $timestamp = new Timestamp();
            $timestamp->fromDateTime($dateTime);
            $event->setEventTimestamp($timestamp);
        } catch (\Exception $e) {
            error_log(sprintf('Skipping event with invalid timestamp: %s', $eventRecord['timestamp']));
            continue;
        }

        if (empty($eventRecord['transactionId'])) {
            error_log('Skipping event with no transaction ID');
            continue;
        }
        $event->setTransactionId($eventRecord['transactionId']);

        if (!empty($eventRecord['eventSource'])) {
            try {
                $event->setEventSource(EventSource::value($eventRecord['eventSource']));
            } catch (\UnexpectedValueException $e) {
                error_log('Skipping event with invalid event source: ' . $eventRecord['eventSource']);
                continue;
            }
        }

        if (!empty($eventRecord['gclid'])) {
            $event->setAdIdentifiers((new AdIdentifiers())->setGclid($eventRecord['gclid']));
        }

        if (!empty($eventRecord['currency'])) {
            $event->setCurrency($eventRecord['currency']);
        }

        if (isset($eventRecord['value'])) {
            $event->setConversionValue($eventRecord['value']);
        }

        $userData = new UserData();
        $identifiers = [];

        if (!empty($eventRecord['emails'])) {
            foreach ($eventRecord['emails'] as $email) {
                try {
                    $preparedEmail = $formatter->processEmailAddress($email, Encoding::Hex);
                    $identifiers[] = (new UserIdentifier())->setEmailAddress($preparedEmail);
                } catch (\InvalidArgumentException $e) {
                    // Skips invalid input.
                    error_log(sprintf('Skipping invalid email: %s', $e->getMessage()));
                    continue;
                }
            }
        }

        if (!empty($eventRecord['phoneNumbers'])) {
            foreach ($eventRecord['phoneNumbers'] as $phoneNumber) {
                try {
                    $preparedPhoneNumber = $formatter->processPhoneNumber($phoneNumber, Encoding::Hex);
                    $identifiers[] = (new UserIdentifier())->setPhoneNumber($preparedPhoneNumber);
                } catch (\InvalidArgumentException $e) {
                    // Skips invalid input.
                    error_log(sprintf('Skipping invalid phone number: %s', $e->getMessage()));
                    continue;
                }
            }
        }

        if (!empty($identifiers)) {
            $userData->setUserIdentifiers($identifiers);
            $event->setUserData($userData);
        }
        $events[] = $event;
    }

    // Builds the destination for the request.
    $destination = (new Destination())
        ->setOperatingAccount((new ProductAccount())
            ->setAccountType($operatingAccountType)
            ->setAccountId($operatingAccountId))
        ->setProductDestinationId($conversionActionId);

    if ($loginAccountType !== null && $loginAccountId !== null) {
        $destination->setLoginAccount((new ProductAccount())
            ->setAccountType($loginAccountType)
            ->setAccountId($loginAccountId));
    }

    if ($linkedAccountType !== null && $linkedAccountId !== null) {
        $destination->setLinkedAccount((new ProductAccount())
            ->setAccountType($linkedAccountType)
            ->setAccountId($linkedAccountId));
    }

    $client = new IngestionServiceClient();
    try {
        $requestCount = 0;
        // Batches requests to send up to the maximum number of events per request.
        foreach (array_chunk($events, MAX_EVENTS_PER_REQUEST) as $eventsBatch) {
            $requestCount++;
            // Builds the request.
            $request = (new IngestEventsRequest())
                ->setDestinations([$destination])
                ->setEvents($eventsBatch)
                ->setConsent((new Consent())
                    ->setAdUserData(ConsentStatus::CONSENT_GRANTED)
                    ->setAdPersonalization(ConsentStatus::CONSENT_GRANTED)
                )
                ->setValidateOnly($validateOnly)
                ->setEncoding(DataManagerEncoding::HEX);

            echo "Request:\n" . json_encode(json_decode($request->serializeToJsonString()), JSON_PRETTY_PRINT) . "\n";
            $response = $client->ingestEvents($request);
            echo "Response for request #{$requestCount}:\n" . json_encode(json_decode($response->serializeToJsonString()), JSON_PRETTY_PRINT) . "\n";
        }
        echo "# of requests sent: {$requestCount}\n";
    } catch (ApiException $e) {
        echo 'Error sending request: ' . $e->getMessage() . "\n";
    } finally {
        $client->close();
    }
}

// Command-line argument parsing
$options = getopt(
    '',
    [
        'operating_account_type:',
        'operating_account_id:',
        'login_account_type::',
        'login_account_id::',
        'linked_account_type::',
        'linked_account_id::',
        'conversion_action_id:',
        'json_file:',
        'validate_only::'
    ]
);

$operatingAccountType = $options['operating_account_type'] ?? null;
$operatingAccountId = $options['operating_account_id'] ?? null;
$conversionActionId = $options['conversion_action_id'] ?? null;
$jsonFile = $options['json_file'] ?? null;

// Only validates requests by default.
$validateOnly = true;
if (array_key_exists('validate_only', $options)) {
    $value = $options['validate_only'];
    // `getopt` with `::` returns boolean `false` if the option is passed without a value.
    if ($value === false || !in_array($value, ['true', 'false'], true)) {
        echo "Error: --validate_only requires a value of 'true' or 'false'.\n";
        exit(1);
    }
    $validateOnly = ($value === 'true');
}

if (empty($operatingAccountType) || empty($operatingAccountId) || empty($conversionActionId) || empty($jsonFile)) {
    echo 'Usage: php ingest_events.php ' .
        '--operating_account_type=<account_type> ' .
        '--operating_account_id=<account_id> ' .
        '--conversion_action_id=<conversion_action_id> ' .
        "--json_file=<path_to_json>\n" .
        'Optional: --login_account_type=<account_type> --login_account_id=<account_id> ' .
        '--linked_account_type=<account_type> --linked_account_id=<account_id> ' .
        "--validate_only=<true|false>\n";
    exit(1);
}

// Converts the operating account type string to an AccountType enum.
$parsedOperatingAccountType = AccountType::value($operatingAccountType);

if (isset($options['login_account_type']) != isset($options['login_account_id'])) {
    throw new \InvalidArgumentException(
        'Must specify either both or neither of login account type and login account ID'
    );
}

$parsedLoginAccountType = null;
if (isset($options['login_account_type'])) {
    // Converts the login account type string to an AccountType enum.
    $parsedLoginAccountType = AccountType::value($options['login_account_type']);
}

if (isset($options['linked_account_type']) != isset($options['linked_account_id'])) {
    throw new \InvalidArgumentException(
        'Must specify either both or neither of linked account type and linked account ID'
    );
}

$parsedLinkedAccountType = null;
if (isset($options['linked_account_type'])) {
    // Converts the linked account type string to an AccountType enum.
    $parsedLinkedAccountType = AccountType::value($options['linked_account_type']);
}

main(
    $parsedOperatingAccountType,
    $operatingAccountId,
    $conversionActionId,
    $jsonFile,
    $validateOnly,
    $parsedLoginAccountType,
    $options['login_account_id'] ?? null,
    $parsedLinkedAccountType,
    $options['linked_account_id'] ?? null
);

ingest_events.php

পাইথন 

#!/usr/bin/env python
# Copyright 2025 Google LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
"""Sample of sending an IngestEventsRequest without encryption."""


import argparse
import json
import logging
from typing import Any, Dict, List, Optional

from google.ads import datamanager_v1
from google.ads.datamanager_util import Formatter
from google.ads.datamanager_util.format import Encoding
from google.protobuf.timestamp_pb2 import Timestamp

_logger = logging.getLogger(__name__)

# The maximum number of events allowed per request.
_MAX_EVENTS_PER_REQUEST = 10_000


def main(
    operating_account_type: datamanager_v1.ProductAccount.AccountType,
    operating_account_id: str,
    conversion_action_id: str,
    json_file: str,
    validate_only: bool,
    login_account_type: Optional[
        datamanager_v1.ProductAccount.AccountType
    ] = None,
    login_account_id: Optional[str] = None,
    linked_account_type: Optional[
        datamanager_v1.ProductAccount.AccountType
    ] = None,
    linked_account_id: Optional[str] = None,
) -> None:
    """Runs the sample.
    Args:
     operating_account_type: the account type of the operating account.
     operating_account_id: the ID of the operating account.
     json_file: the JSON file containing event data.
     validate_only: whether to enable validate_only on the request.
     login_account_type: the account type of the login account.
     login_account_id: the ID of the login account.
     linked_account_type: the account type of the linked account.
     linked_account_id: the ID of the linked account.
    """

    # Gets an instance of the formatter.
    formatter: Formatter = Formatter()

    # Reads the input file.
    event_rows: List[Dict[str, Any]] = read_event_data_file(json_file)
    events: List[datamanager_v1.Event] = []
    for event_row in event_rows:
        event = datamanager_v1.Event()
        try:
            event_timestamp = Timestamp()
            event_timestamp.FromJsonString(str(event_row["timestamp"]))
            event.event_timestamp = event_timestamp
        except ValueError:
            _logger.warning(
                "Invalid timestamp format: %s. Skipping row.",
                event_row["timestamp"],
            )
            continue

        if "transactionId" not in event_row:
            _logger.warning("Skipping event with no transaction ID")
            continue
        event.transaction_id = event_row["transactionId"]

        if "eventSource" in event_row:
            event.event_source = event_row["eventSource"]

        if "gclid" in event_row:
            event.ad_identifiers = datamanager_v1.AdIdentifiers(
                gclid=event_row["gclid"]
            )

        if "currency" in event_row:
            event.currency = event_row["currency"]

        if "value" in event_row:
            event.conversion_value = event_row["value"]

        user_data = datamanager_v1.UserData()
        # Adds a UserIdentifier for each valid email address for the event row.
        if "emails" in event_row:
            for email in event_row["emails"]:
                try:
                    processed_email: str = formatter.process_email_address(
                        email, Encoding.HEX
                    )
                    user_data.user_identifiers.append(
                        datamanager_v1.UserIdentifier(
                            email_address=processed_email
                        )
                    )
                except ValueError:
                    # Skips invalid input.
                    _logger.warning(
                        "Invalid email address: %s. Skipping.",
                        event_row["email_address"],
                    )

        # Adds a UserIdentifier for each valid phone number for the event row.
        if "phoneNumbers" in event_row:
            for phone_number in event_row["phoneNumbers"]:
                try:
                    processed_phone: str = formatter.process_phone_number(
                        phone_number, Encoding.HEX
                    )
                    user_data.user_identifiers.append(
                        datamanager_v1.UserIdentifier(
                            phone_number=processed_phone
                        )
                    )
                except ValueError:
                    # Skips invalid input.
                    _logger.warning(
                        "Invalid phone: %s. Skipping.",
                        event_row["phone_number"],
                    )

        if user_data.user_identifiers:
            event.user_data = user_data

        # Adds the event to the list of events to send in the request.
        events.append(event)

    # Configures the destination.
    destination: datamanager_v1.Destination = datamanager_v1.Destination()
    destination.operating_account.account_type = operating_account_type
    destination.operating_account.account_id = operating_account_id
    destination.product_destination_id = str(conversion_action_id)
    if login_account_type or login_account_id:
        if bool(login_account_type) != bool(login_account_id):
            raise ValueError(
                "Must specify either both or neither of login "
                + "account type and login account ID"
            )
        destination.login_account.account_type = login_account_type
        destination.login_account.account_id = login_account_id
    if linked_account_type or linked_account_id:
        if bool(linked_account_type) != bool(linked_account_id):
            raise ValueError(
                "Must specify either both or neither of linked account "
                + "type and linked account ID"
            )
        destination.linked_account.account_type = linked_account_type
        destination.linked_account.account_id = linked_account_id

    # Creates a client for the ingestion service.
    client: datamanager_v1.IngestionServiceClient = (
        datamanager_v1.IngestionServiceClient()
    )

    # Batches requests to send up to the maximum number of events per
    # request.
    request_count = 0
    for i in range(0, len(events), _MAX_EVENTS_PER_REQUEST):
        request_count += 1
        events_batch = events[i : i + _MAX_EVENTS_PER_REQUEST]
        # Sends the request.
        request: datamanager_v1.IngestEventsRequest = (
            datamanager_v1.IngestEventsRequest(
                destinations=[destination],
                # Adds events from the current batch.
                events=events_batch,
                consent=datamanager_v1.Consent(
                    ad_user_data=datamanager_v1.ConsentStatus.CONSENT_GRANTED,
                    ad_personalization=datamanager_v1.ConsentStatus.CONSENT_GRANTED,
                ),
                # Sets encoding to match the encoding used.
                encoding=datamanager_v1.Encoding.HEX,
                # Sets validate_only. If true, then the Data Manager API only
                # validates the request but doesn't apply changes.
                validate_only=validate_only,
            )
        )

        # Sends the request.
        response: datamanager_v1.IngestEventsResponse = client.ingest_events(
            request=request
        )

        # Logs the response.
        _logger.info("Response for request #%d:\n%s", request_count, response)

    _logger.info("# of requests sent: %d", request_count)


def read_event_data_file(json_file: str) -> List[Dict[str, Any]]:
    """Reads the JSON-formatted event data file.
    Args:
      json_file: the event data file.
    """
    with open(json_file, "r") as f:
        return json.load(f)


if __name__ == "__main__":
    # Configures logging.
    logging.basicConfig(level=logging.INFO)

    parser = argparse.ArgumentParser(
        description=("Sends events from a JSON file to a destination."),
        fromfile_prefix_chars="@",
    )
    # The following argument(s) should be provided to run the example.
    parser.add_argument(
        "--operating_account_type",
        type=str,
        required=True,
        help="The account type of the operating account.",
    )
    parser.add_argument(
        "--operating_account_id",
        type=str,
        required=True,
        help="The ID of the operating account.",
    )
    parser.add_argument(
        "--conversion_action_id",
        type=int,
        required=True,
        help="The ID of the conversion action",
    )
    parser.add_argument(
        "--login_account_type",
        type=str,
        required=False,
        help="The account type of the login account.",
    )
    parser.add_argument(
        "--login_account_id",
        type=str,
        required=False,
        help="The ID of the login account.",
    )
    parser.add_argument(
        "--linked_account_type",
        type=str,
        required=False,
        help="The account type of the linked account.",
    )
    parser.add_argument(
        "--linked_account_id",
        type=str,
        required=False,
        help="The ID of the linked account.",
    )
    parser.add_argument(
        "--json_file",
        type=str,
        required=True,
        help="JSON file containing user data to ingest.",
    )
    parser.add_argument(
        "--validate_only",
        choices=["true", "false"],
        default="true",
        help="""Whether to enable validate_only on the request. Must be
        'true' or 'false'. Defaults to 'true'.""",
    )
    args = parser.parse_args()

    main(
        args.operating_account_type,
        args.operating_account_id,
        args.conversion_action_id,
        args.json_file,
        args.validate_only == "true",
        args.login_account_type,
        args.login_account_id,
        args.linked_account_type,
        args.linked_account_id,
    )

ingest_events.py

সফল প্রতিক্রিয়া

একটি সফল অনুরোধের ফলে একটি প্রতিক্রিয়া পাওয়া যায়, যাতে একটি অবজেক্ট থাকে এবং সেই অবজেক্টটিতে একটি requestId অন্তর্ভুক্ত থাকে। 

{
  "requestId": "126365e1-16d0-4c81-9de9-f362711e250a"
}

ফেরত আসা requestId টি রেকর্ড করে রাখুন, যাতে অনুরোধের প্রতিটি গন্তব্য প্রক্রিয়াকরণের সাথে সাথে আপনি ডায়াগনস্টিকস পুনরুদ্ধার করতে পারেন।

ব্যর্থতার প্রতিক্রিয়া

একটি ব্যর্থ অনুরোধের ফলে 400 Bad Request এর মতো একটি ত্রুটিপূর্ণ প্রতিক্রিয়া স্ট্যাটাস কোড এবং ত্রুটির বিবরণসহ একটি প্রতিক্রিয়া পাওয়া যায়।

উদাহরণস্বরূপ, হেক্স এনকোডেড মানের পরিবর্তে একটি সাধারণ টেক্সট স্ট্রিং সম্বলিত emailAddress ব্যবহার করলে নিম্নলিখিত প্রতিক্রিয়া তৈরি হয়: 

{
  "error": {
    "code": 400,
    "message": "There was a problem with the request.",
    "status": "INVALID_ARGUMENT",
    "details": [
      {
        "@type": "type.googleapis.com/google.rpc.ErrorInfo",
        "reason": "INVALID_ARGUMENT",
        "domain": "datamanager.googleapis.com"
      },
      {
        "@type": "type.googleapis.com/google.rpc.BadRequest",
        "fieldViolations": [
          {
            "field": "events.events[0].user_data.user_identifiers",
            "description": "Email is not hex encoded.",
            "reason": "INVALID_HEX_ENCODING"
          }
        ]
      }
    ]
  }
}

একটি emailAddress যা হ্যাশ করা হয়নি এবং শুধুমাত্র হেক্স এনকোড করা হয়েছে, তা নিম্নলিখিত প্রতিক্রিয়া তৈরি করে: 

{
  "error": {
    "code": 400,
    "message": "There was a problem with the request.",
    "status": "INVALID_ARGUMENT",
    "details": [
      {
        "@type": "type.googleapis.com/google.rpc.ErrorInfo",
        "reason": "INVALID_ARGUMENT",
        "domain": "datamanager.googleapis.com"
      },
      {
        "@type": "type.googleapis.com/google.rpc.BadRequest",
        "fieldViolations": [
          {
            "field": "events.events[0]",
            "reason": "INVALID_SHA256_FORMAT"
          }
        ]
      }
    ]
  }
}

একাধিক গন্তব্যের জন্য ইভেন্ট পাঠান

আপনার ডেটাতে যদি বিভিন্ন গন্তব্যের ইভেন্ট থাকে, তাহলে আপনি ডেস্টিনেশন রেফারেন্স ব্যবহার করে সেগুলোকে একই অনুরোধে পাঠাতে পারেন।

উদাহরণস্বরূপ, যদি আপনার কনভার্সন অ্যাকশন আইডি 123456789 এর জন্য একটি ইভেন্ট এবং কনভার্সন অ্যাকশন আইডি 777111122 এর জন্য আরেকটি ইভেন্ট থাকে, তাহলে প্রতিটি Destination reference সেট করে উভয় ইভেন্ট একটিমাত্র রিকোয়েস্টে পাঠান। reference ব্যবহারকারী-নির্ধারিত। একমাত্র শর্ত হলো প্রতিটি Destination একটি অনন্য reference থাকতে হবে। রিকোয়েস্টটির জন্য পরিবর্তিত destinations তালিকাটি নিচে দেওয়া হলো: 

  "destinations": [
    {
      "operatingAccount": {
        "accountType": "OPERATING_ACCOUNT_TYPE",
        "accountId": "OPERATING_ACCOUNT_ID"
      },

      "loginAccount": {
        "accountType": "LOGIN_ACCOUNT_TYPE",
        "accountId": "LOGIN_ACCOUNT_ID"
      },

      "productDestinationId": "PRODUCT_DESTINATION_ID",
      "reference": "destination_a"
    },
    {
      "operatingAccount": {
        "accountType": "OPERATING_ACCOUNT_2_TYPE",
        "accountId": "OPERATING_ACCOUNT_2_ID"
      },

      "loginAccount": {
        "accountType": "LOGIN_ACCOUNT_2_TYPE",
        "accountId": "LOGIN_ACCOUNT_2_ID"
      },

      "productDestinationId": "777111122",
      "reference": "destination_b"
    }
  ]

প্রতিটি Event এক বা একাধিক নির্দিষ্ট গন্তব্যে পাঠানোর জন্য সেটির destinationReferences সেট করুন। উদাহরণস্বরূপ, এখানে একটি Event রয়েছে যা শুধুমাত্র প্রথম Destination জন্য, তাই এর destinationReferences তালিকায় কেবল প্রথম Destination reference রয়েছে: 

{
   "adIdentifiers": {
      "gclid": "GCLID_1"
   },
   "conversionValue": 1.99,
   "currency": "USD",
   "eventTimestamp": "2025-06-10T20:07:01Z",
   "transactionId": "ABC798654321",
   "eventSource": "WEB",
   "destinationReferences": [
      "destination_a"
   ]
}

destinationReferences ফিল্ডটি একটি তালিকা, তাই আপনি একটি ইভেন্টের জন্য একাধিক গন্তব্য নির্দিষ্ট করতে পারেন। যদি আপনি কোনো Event destinationReferences সেট না করেন, তাহলে ডেটা ম্যানেজার এপিআই অনুরোধে থাকা সমস্ত গন্তব্যে ইভেন্টটি পাঠিয়ে দেয়।

যদি কোনো ইভেন্টের একাধিক গন্তব্য থাকে, তাহলে ডেটা ম্যানেজার এপিআই প্রতিটি গন্তব্যে প্রাসঙ্গিক ফিল্ডগুলো পাঠায়। উদাহরণস্বরূপ, যদি কোনো ইভেন্টের একটি গুগল অ্যাডস গন্তব্য এবং একটি গুগল অ্যানালিটিক্স গন্তব্য থাকে, তাহলে এপিআইটি ইভেন্টটিকে গুগল অ্যানালিটিক্স গন্তব্যে পাঠানোর সময় clientId বা eventName মতো গুগল অ্যানালিটিক্স ফিল্ডগুলো অন্তর্ভুক্ত করে, এবং ইভেন্টটিকে গুগল অ্যাডস গন্তব্যে পাঠানোর সময় customVariables মতো গুগল অ্যাডস ফিল্ডগুলো অন্তর্ভুক্ত করে।

পরবর্তী পদক্ষেপ

পূর্ববর্তী
ইভেন্ট ওভারভিউ