Functions — github.com/awslabs/amazon-redshift-utils

hub / github.com/awslabs/amazon-redshift-utils / functions

Functions735 in github.com/awslabs/amazon-redshift-utils

⨍ Functions 735◇ Types & classes 84 ↳ Endpoints 15

↓ 172 callersMethodappend

(self, value)

src/UnloadCopyUtility/util/tasks.py:102

↓ 117 callersMethodexecute

Should peform the task and raise exceptions if anything goes wrong. :return:

src/UnloadCopyUtility/util/tasks.py:139

↓ 48 callersFunctioncomment

(string)

src/ColumnEncodingUtility/analyze-schema-compression.py:145

↓ 39 callersFunctionadd_to_config

(constant)

src/config_constants.py:80

↓ 34 callersFunctioncomment

(string)

src/AnalyzeVacuumUtility/lib/analyze_vacuum.py:74

↓ 18 callersFunctionmillisToMinutesAndSeconds

(milliseconds, digits = 2)

src/SimpleReplay/gui/src/helpers/msFormatter.js:8

↓ 15 callersMethodget_schema

(self)

src/UnloadCopyUtility/util/resources.py:233

↓ 13 callersFunctionget_config_value

(labels, configs)

src/SystemTablePersistence/snapshot_system_stats.py:44

↓ 13 callersMethodget_table

(self)

src/UnloadCopyUtility/util/resources.py:314

↓ 12 callersFunctionexecuteddls

(srccursor, tgtcursor, privquery, tgtuser, ddltype=None)

src/MetadataTransfer/userprivs.py:125

↓ 11 callersMethodadd_task

(self, task, dependency_of=None, dependencies=None)

src/UnloadCopyUtility/util/tasks.py:21

↓ 11 callersFunctionrequest_s3_data

Iterates through selected replays to compile data results of given file in one data frame Analysis uses replayerrors000, sys_query_history000, and

src/SimpleReplay/api/app.py:31

↓ 10 callersFunctionexecute_query

(string)

src/ColumnEncodingUtility/analyze-schema-compression.py:110

↓ 10 callersMethodrestorestatus

(self, output)

src/MultipleTableRestoreUtility/multitablerestore.py:57

↓ 9 callersMethodassertParameterSetWithValue

(self, parameter_key, parameter_value)

src/UnloadCopyUtility/tests/stack_parameters_builder_unittests.py:15

↓ 9 callersFunctionexecute_api_sql

(queries, dbCluster=None, dbWorkgroup=None, dbPort=5439, dbName=None, dbUser=None)

src/UserLastLogin/user_last_login.py:33

↓ 9 callersMethodget_config_key_values_updated_with_cli_args

(self, argv)

src/UnloadCopyUtility/global_config.py:227

↓ 9 callersMethodis_present

(self, force_update=False)

src/UnloadCopyUtility/util/resources.py:95

↓ 9 callersFunctionrun_commands

(conn, commands, cw=None, cluster_name=None, suppress_errors=False)

src/AnalyzeVacuumUtility/lib/analyze_vacuum.py:150

↓ 8 callersMethod__init__

(self, source_resource=None, target_resource=None, s3_details=None)

src/UnloadCopyUtility/util/tasks.py:130

↓ 8 callersMethoddecrypt

(self, b64_encoded_value)

src/UnloadCopyUtility/util/kms_helper.py:16

↓ 8 callersMethodget_db

(self)

src/UnloadCopyUtility/util/resources.py:159

↓ 8 callersMethodstart_time

(self)

src/SimpleReplay/replay.py:160

↓ 8 callersFunctionusage

(with_message)

src/ColumnEncodingUtility/analyze-schema-compression.py:865

↓ 7 callersMethod__init__

(self, path_to_v_generate, view_start)

src/UnloadCopyUtility/util/sql/ddl_generators.py:13

↓ 7 callersFunctionget_env_var

(name)

src/QMRNotificationUtility/lambda/lambda_function.py:29

↓ 7 callersMethodget_name

(self, stack_name=None)

src/UnloadCopyUtility/tests/cloudformation/run_stack.py:27

↓ 7 callersMethodget_safe_value

(value)

src/UnloadCopyUtility/util/tasks.py:121

↓ 7 callersMethodindex

(self, value, start=0, stop=None)

src/UnloadCopyUtility/util/tasks.py:108

↓ 6 callersFunctioncleanup

(conn)

src/ColumnEncodingUtility/analyze-schema-compression.py:135

↓ 6 callersMethodget_db

(self)

src/UnloadCopyUtility/util/redshift_cluster.py:110

↓ 6 callersMethodget_ddl_for_different_relation

(ddl, new_table_name=None, new_schema_name=None)

src/UnloadCopyUtility/util/sql/ddl_generators.py:93

↓ 6 callersMethodget_host

(self)

src/UnloadCopyUtility/util/redshift_cluster.py:98

↓ 6 callersMethodget_key_for_cli_flag

(cli_flag)

src/UnloadCopyUtility/global_config.py:316

↓ 6 callersMethodget_sql_without_commands_newlines_and_whitespace

(input_sql_text)

src/UnloadCopyUtility/util/sql/sql_text_helpers.py:122

↓ 6 callersMethodget_user

(self)

src/UnloadCopyUtility/util/redshift_cluster.py:79

↓ 6 callersFunctionprepareSelectOptions

(field, data)

src/SimpleReplay/gui/src/helpers/PrepareOptions.js:7

↓ 6 callersFunctionremove_prefix

Helper function to remove prefix from a string if it exists

src/LakeFormationMigrationUtility/rs_privs_to_lf.py:535

↓ 6 callersMethodrun

(self)

src/SimpleReplay/replay.py:326

↓ 6 callersFunctionrun_commands

(conn, commands)

src/ColumnEncodingUtility/analyze-schema-compression.py:413

↓ 6 callersMethodsupported_filters

()

src/SimpleReplay/replay.py:170

↓ 5 callersMethod__init__

(self, name, value)

src/UnloadCopyUtility/global_config.py:11

↓ 5 callersMethod__init__

(self)

src/UnloadCopyUtility/util/resources.py:22

↓ 5 callersFunctionbucket_dict

(bucket_url)

src/SimpleReplay/util.py:266

↓ 5 callersFunctionexecute_query

(conn, query)

src/AnalyzeVacuumUtility/lib/analyze_vacuum.py:43

↓ 5 callersMethodget_cluster

(self)

src/UnloadCopyUtility/util/resources.py:51

↓ 5 callersMethodget_cluster

(self)

src/UnloadCopyUtility/util/resources.py:162

↓ 5 callersMethodget_create_sql

(self, generate=False)

src/UnloadCopyUtility/util/resources.py:30

↓ 5 callersFunctionget_pg_conn

()

src/ColumnEncodingUtility/analyze-schema-compression.py:160

↓ 5 callersMethodget_sql_without_comments

(input_sql_text)

src/UnloadCopyUtility/util/sql/sql_text_helpers.py:116

↓ 5 callersMethodset_db

(self, db)

src/UnloadCopyUtility/util/redshift_cluster.py:113

↓ 4 callersMethodadd_dependency_to_task

(self, task, dependency)

src/UnloadCopyUtility/util/tasks.py:38

↓ 4 callersFunctionbucket_dict

(bucket_url)

src/SimpleReplay/api/utils.py:14

↓ 4 callersMethodcreate

config_parameters has global_config_parameters. If that is the case then they will be checked prior to creation :param sql_text:

src/UnloadCopyUtility/util/resources.py:54

↓ 4 callersFunctioncreate_lf_command

Helper function to create a Lake Formation command with consistent formatting action can be 'grant' or 'revoke'

src/LakeFormationMigrationUtility/rs_privs_to_lf.py:560

↓ 4 callersFunctioncreate_table_resource_json

Helper function to create the resource JSON for a table or schema

src/LakeFormationMigrationUtility/rs_privs_to_lf.py:574

↓ 4 callersFunctioncreateobjs

(objtype, query, objcon, srccursor, tgtcursor, tgtcluster)

src/MetadataTransfer/metadatacopy.py:16

↓ 4 callersFunctionfilter_data

(data, replay, query_types=None, users=None, duration=None)

src/SimpleReplay/api/utils.py:115

↓ 4 callersFunctionget_connection_key

(database_name, username, pid)

src/SimpleReplay/replay.py:764

↓ 4 callersFunctionget_env_var

(name, default_value)

src/ColumnEncodingUtility/analyze-schema-compression.py:78

↓ 4 callersMethodget_first_double_quoted_identifier

(string)

src/UnloadCopyUtility/util/sql/sql_text_helpers.py:173

↓ 4 callersMethodget_pk

(self)

src/SimpleReplay/audit_logs_parsing.py:97

↓ 4 callersMethodget_port

(self)

src/UnloadCopyUtility/util/redshift_cluster.py:104

↓ 4 callersFunctionget_principal_identifier

Generate the principal identifier for Lake Formation permissions based on identity name for IDC users

src/LakeFormationMigrationUtility/rs_privs_to_lf.py:541

↓ 4 callersMethodget_region_name

(self)

src/UnloadCopyUtility/util/redshift_cluster.py:221

↓ 4 callersMethodget_status

(self)

src/UnloadCopyUtility/tests/cloudformation/run_stack.py:63

↓ 4 callersMethodget_value

(self)

src/UnloadCopyUtility/global_config.py:26

↓ 4 callersFunctiongetiamcredentials

(dbhost=None,dbname=None, dbuser=None)

src/MetadataTransfer/redshiftfunc.py:8

↓ 4 callersFunctioninit_stats

(stats_dict)

src/SimpleReplay/replay.py:934

↓ 4 callersMethodmake_config_parameter

(default_config_parameter, new_value)

src/UnloadCopyUtility/global_config.py:59

↓ 4 callersFunctionmatches_filters

Check if the object matches the filters. The object just needs to provide a supported_filters() function. This also assumes filters has already

src/SimpleReplay/replay.py:586

↓ 4 callersFunctionraise_config_exception

(item, message=None)

src/WorkloadManagementScheduler/wlm_scheduler.py:60

↓ 4 callersMethodremove

(self, value)

src/UnloadCopyUtility/util/tasks.py:111

↓ 4 callersMethodset_password

(self, password)

src/UnloadCopyUtility/util/redshift_cluster.py:95

↓ 4 callersMethodset_user

(self, user)

src/UnloadCopyUtility/util/redshift_cluster.py:82

↓ 3 callersMethod__init__

(self, region_name)

src/UnloadCopyUtility/util/s3_utils.py:12

↓ 3 callersMethod__str__

(self)

src/UnloadCopyUtility/util/resources.py:173

↓ 3 callersMethod__str__

(self)

src/SimpleReplay/PreviousVersion/ParseUserActivityLog.py:171

↓ 3 callersMethodadd_filters

(self, filters)

src/UnloadCopyUtility/util/sql/ddl_generators.py:29

↓ 3 callersFunctionbuild_pdf_tables

Builds formatted tables sections for a list of tables @param story: list, pdf elements @param tables: list, tables to build @param repor

src/SimpleReplay/report_util.py:275

↓ 3 callersFunctioncalc_diff

(replay_start, timestamp)

src/SimpleReplay/api/utils.py:99

↓ 3 callersMethodcli_argument_to_config_name

(cli_argument)

src/UnloadCopyUtility/tests/cloudformation/run_stack.py:213

↓ 3 callersFunctioncluster_dict

Create a object-like dictionary from cluster endpoint

src/SimpleReplay/util.py:197

↓ 3 callersFunctioncollect_stats

Aggregate the per-thread stats into the overall stats for this aggregated process

src/SimpleReplay/replay.py:898

↓ 3 callersFunctioncurrent_offset_ms

(ref_time)

src/SimpleReplay/replay.py:611

↓ 3 callersFunctiondb_connect

Connect to the database using the method specified by interface (either psql or odbc) :param drop_return: if True, don't store returned value.

src/SimpleReplay/util.py:99

↓ 3 callersFunctiondelete_s3_file

(bucket_name, file_key)

src/RedshiftIDCMigrationUtility/idc_add_users_groups_roles_psets.py:248

↓ 3 callersFunctiondf_to_np

Maps a data frame to a numpy array :param heading: list, column names :param df: Dataframe, data being converted

src/SimpleReplay/report_util.py:175

↓ 3 callersMethoddrop

(self)

src/UnloadCopyUtility/util/resources.py:91

↓ 3 callersFunctionget_and_write_data

(conn, query, s3_key, config)

src/RedshiftIDCMigrationUtility/idc_redshift_unload_indatabase_groups_roles_users.py:182

↓ 3 callersMethodget_cluster_identifier

(self)

src/UnloadCopyUtility/util/redshift_cluster.py:224

↓ 3 callersFunctionget_connection_credentials

( username, database=None, max_attempts=10, skip_cache=False )

src/SimpleReplay/replay.py:1560

↓ 3 callersMethodget_default_config_parameters

(self)

src/UnloadCopyUtility/global_config.py:203

↓ 3 callersFunctionget_log_formatter

Define the log format, with the option to prepend process and job/thread to each message

src/SimpleReplay/util.py:69

↓ 3 callersMethodget_password

(self)

src/UnloadCopyUtility/util/redshift_cluster.py:85

↓ 3 callersMethodget_query_full_result_as_list_of_dict

Inefficient way to store data but nice and easy for queries with small result sets. :return:

src/UnloadCopyUtility/util/redshift_cluster.py:278

↓ 3 callersMethodget_query_sql_text_with_parameters_replaced

(self, sql_text)

src/UnloadCopyUtility/util/resources.py:176

↓ 3 callersFunctionget_redshift_credentials

(config)

src/LakeFormationMigrationUtility/tests/integration_test/test_int_redshift_to_lakeformation.py:12

↓ 3 callersMethodget_sql

(self)

src/UnloadCopyUtility/util/sql/ddl_generators.py:25

↓ 3 callersMethodis_temporary_credential_expired

(self)

src/UnloadCopyUtility/util/redshift_cluster.py:134

next →1–100 of 735, ranked by callers