etl.py 文件源码

def remote_sql_count(self):
        """SQL QUERY FOR COUNT ROW IN REMOTE SOURCE"""
        try:
            return 'SELECT COUNT(*) AS rows_count FROM ({sql}) AS CHITER;'. \
                format(
                    sql=self.remote_etl_sql().compile(
                        compile_kwargs={"literal_binds": True})
                )
        except AttributeError:
            return 'SELECT COUNT(*) AS rows_count FROM ({sql}) AS CHITER;'. \
                format(
                    sql=self.remote_etl_sql()
                )