Существует ли способ создания динамического c семейства столбцов в AWS Управляемых службах Cassandra, как мы это делаем в Cassandra или любым другим способом, с помощью которого мы можем динамически добавлять столбцы в таблицу в AWS Управляемый Cassandra Services.
Я знаю, что мы можем сделать это на Cassandra , но AWS Примеры кодирования управляемых услуг Cassandra приветствуются.
Кроме того, существует ли способ вставки столбцов в таблицу AWS Managed Cassandra Service без указания имен столбцов. В настоящее время у меня есть предопределенные структуры таблиц, и я должен использовать все имена столбцов при вставке данных в таблицу. Я хочу динамически вставлять столбцы в каждую строку таблицы
например:
prepared = session.prepare("""
INSERT INTO Hiringsheet2 (
profile_id, name, company, email, phone, schools, location, links,
files, candidate_owner_name, candidate_owner_email, origin, sources, tags, referred, referrer, is_social_referral,
social_referrer, is_employee_referral, employee_referrer, is_manual_referral, created_at, date_submitted,
application_id, posting_id, posting_title, posting_owner_name, posting_owner_email, posting_hiring_manager_name,
posting_hiring_manager_email, posting_location, posting_team, posting_level, posting_commitment, profile_archive_status,
posting_archive_status, posting_archive_reason, posting_archived_at, current_stage, last_story_at,
last_advanced_at, hired, start_date, snoozed_until, stage_new_lead, stage_reached_out, stage_responded,
stage_new_applicant, stage_contacted, stage_resume_screening_pending, stage_phone_or_initial_process,
stage_phone_or_initial_completed, stage_tech_or_non_tech_interview_1_in_process,
stage_tech_or_non_tech_interview_1_completed, stage_tech_or_non_tech_interview_2_in_process,
stage_tech_or_non_tech_interview_2_completed, stage_tech_or_non_tech_interview_3_in_process,
stage_tech_or_non_tech_interview_3_completed, stage_hiring_manager_and_cultural_fit_interview_in_process,
stage_hiring_manager_and_cultural_fit_interview_completed, stage_hr_or_exec_interview_in_process,
stage_hr_or_exec_interview_completed, stage_reference_check, stage_offer_extended, stage_offer_accepted,
stage_offer_declined, application_sources, posting_department, manual_referrers, profile_archive_reason,
requisition_for_hire_id, requisition_for_hire_requisition_code, contact_id, version
)
VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
""")
try:
#if is_snapshot is None:
session.execute(prepared.bind((
row['profile_id'], row['name'],
row['company'], row['email'],
row['phone'], row['schools'], row['location'], row['links'],
row['files'], row['candidate_owner_name'], row['candidate_owner_email'],
row['origin'], row['sources'], row['tags'], row['referred'], row['referrer'],
row['is_social_referral'], row['social_referrer'], row['is_employee_referral'], row['employee_referrer'],
row['is_manual_referral'], row['created_at'], row['date_submitted'], row['application_id'], row['posting_id'], row['posting_title'], row['posting_owner_name'], row['posting_owner_email'], row['posting_hiring_manager_name'], row['posting_hiring_manager_email'], row['posting_location'], row['posting_team'], row['posting_level'], row['posting_commitment'], row['profile_archive_status'], row['posting_archive_status'], row['posting_archive_reason'], row['posting_archived_at'], row['current_stage'], row['last_story_at'], row['last_advanced_at'], row['hired'], row['start_date'], row['snoozed_until'], row['stage_new_lead'], row['stage_reached_out'], row['stage_responded'], row['stage_new_applicant'], row['stage_contacted'], row['stage_resume_screening_pending'], row['stage_phone_or_initial_process'], row['stage_phone_or_initial_completed'], row['stage_tech_or_non_tech_interview_1_in_process'], row['stage_tech_or_non_tech_interview_1_completed'], row['stage_tech_or_non_tech_interview_2_in_process'], row['stage_tech_or_non_tech_interview_2_completed'], row['stage_tech_or_non_tech_interview_3_in_process'], row['stage_tech_or_non_tech_interview_3_completed'], row['stage_hiring_manager_and_cultural_fit_interview_in_process'], row['stage_hiring_manager_and_cultural_fit_interview_completed'], row['stage_hr_or_exec_interview_in_process'], row['stage_hr_or_exec_interview_completed'], row['stage_reference_check'], row['stage_offer_extended'], row['stage_offer_accepted'], row['stage_offer_declined'], row['application_sources'], row['posting_department'],
row['manual_referrers'], row['profile_archive_reason'], row['requisition_for_hire_id'],
row['requisition_for_hire_requisition_code'], row['contact_id'], version
)))