0

我正在尝试使用 PyAthenaJDBC 库来制作一个 python 脚本，该脚本将使用 Athena 查询 S3 存储桶。该库非常棒，但我遇到了格式问题。

我将查询构造为单独函数中的字符串，并将查询字符串传递回cursor.execute(query).

查询字符串中包含引号，如下所示：

SELECT day, elb_name
    ,COUNT (*) AS c
    ,100.0 * (
        1.0 - (
            SUM (
                CASE
                    WHEN elb_response_code LIKE '5%' THEN 1
                    ELSE 0
                END
            ) / cast(COUNT (*) as double)
        )
    ) AS success_rate
    ,100.0 * SUM (
        CASE
            WHEN backend_processing_time < 0.1 THEN 1
            ELSE 0
        END
    ) / cast(COUNT (*) as double) AS t_lt_pt1
    ,100.0 * SUM (
        CASE
            WHEN backend_processing_time < 1 THEN 1
            ELSE 0
        END
    ) / cast(COUNT (*) as double) AS t_lt_1
    ,100.0 * SUM (
        CASE
            WHEN backend_processing_time < 5 THEN 1
            ELSE 0
        END
    ) / cast(COUNT (*) as double) AS t_lt_5
    ,100.0 * SUM (
        CASE
            WHEN backend_processing_time < 10 THEN 1
            ELSE 0
        END
    ) / cast(COUNT (*) as double) AS t_lt_10
    FROM elb_logs_raw_native_part
    WHERE year = '2017' AND
    month = '03' AND
    elb_name is not NULL AND
    elb_name != ''
    GROUP BY day, elb_name
    ORDER BY c DESC

这将导致 `LIKE '5%' 语句中的第二个单引号出现错误。

ValueError: unsupported format character ''' (0x27) at index 186

我可以通过更改库中的这一行来避免错误并成功执行查询https://github.com/laughingman7743/PyAthenaJDBC/blob/master/pyathenajdbc/formatter.py#L115

从return (operation % kwargs).strip()到return (operation).strip()代码中的这一点，operation == query（粘贴在上面）和kwargs == {}

我的具体问题是，我的查询结构是否不正确？或者这是我不了解本地字符串格式的东西，尝试用空字典替换是一个坏主意？

4

1 回答 1

1

如果将查询用作要格式化的字符串，则需要将%希望保留为文字%字符的任何字符加倍。

而不是WHEN elb_response_code LIKE '5%' THEN 1，使用WHEN elb_response_code LIKE '5%%' THEN 1. 在您在 formatter.py 中指定的行运行之后，%%将被转换为单个%.

于 2017-04-22T05:24:58.170 回答