yandextank/plugins/NeUploader/plugin.py
def get_uploader(data_session, column_mapping, overall_only=False):
    """
    :type column_mapping: dict
    :type data_session: DataSession
    """
    overall = {col_name: data_session.new_aggregated_metric(name + ' overall')
               for col_name, name in column_mapping.items()}

    def upload_df(df):
        for col_name, metric in overall.items():
            df['value'] = df[col_name]
            metric.put(df)
    return upload_df
def get_uploader(data_session, column_mapping, overall_only=False):
    """
    :type column_mapping: dict
    :type data_session: DataSession
    """
    overall = {col_name: data_session.new_aggregated_metric(name + ' overall')
               for col_name, name in column_mapping.items()}

    def upload_df(df):
        for col_name, metric in overall.items():
            df['value'] = df[col_name]
            metric.put(df)
    return upload_df
def get_uploader ( data_session , column_mapping , overall_only = False ) : overall = { col_name : data_session . new_aggregated_metric ( name + ' overall' ) for col_name , name in column_mapping . items ( ) } def upload_df ( df ) : for col_name , metric in overall . items ( ) : df [ 'value' ] = df [ col_name ] metric . put ( df ) return upload_df
:type column_mapping: dict
    :type data_session: DataSession
: type column_mapping : dict : type data_session : DataSession