测试订阅消息job时报错

来源：12-9 微信消息模板下：Job处理异步消息

FCBMessi

2021-05-19

python3 manager.py runjob -m queue/index

2021-05-19 02:39:45,121 INFO sqlalchemy.engine.base.Engine SHOW VARIABLES LIKE 'sql_mode'

2021-05-19 02:39:45,121 INFO sqlalchemy.engine.base.Engine ()

2021-05-19 02:39:45,124 INFO sqlalchemy.engine.base.Engine SHOW VARIABLES LIKE 'lower_case_table_names'

2021-05-19 02:39:45,124 INFO sqlalchemy.engine.base.Engine ()

2021-05-19 02:39:45,127 INFO sqlalchemy.engine.base.Engine SELECT DATABASE()

2021-05-19 02:39:45,127 INFO sqlalchemy.engine.base.Engine ()

2021-05-19 02:39:45,128 INFO sqlalchemy.engine.base.Engine show collation where `Charset` = 'utf8mb4' and `Collation` = 'utf8mb4_bin'

2021-05-19 02:39:45,128 INFO sqlalchemy.engine.base.Engine ()

2021-05-19 02:39:45,130 INFO sqlalchemy.engine.base.Engine SELECT CAST('test plain returns' AS CHAR(60)) AS anon_1

2021-05-19 02:39:45,130 INFO sqlalchemy.engine.base.Engine ()

2021-05-19 02:39:45,131 INFO sqlalchemy.engine.base.Engine SELECT CAST('test unicode returns' AS CHAR(60)) AS anon_1

2021-05-19 02:39:45,131 INFO sqlalchemy.engine.base.Engine ()

2021-05-19 02:39:45,132 INFO sqlalchemy.engine.base.Engine SELECT CAST('test collated returns' AS CHAR CHARACTER SET utf8mb4) COLLATE utf8mb4_bin AS anon_1

2021-05-19 02:39:45,132 INFO sqlalchemy.engine.base.Engine ()

2021-05-19 02:39:45,134 INFO sqlalchemy.engine.base.Engine BEGIN (implicit)

2021-05-19 02:39:45,136 INFO sqlalchemy.engine.base.Engine SELECT queue_list.id AS queue_list_id, queue_list.queue_name AS queue_list_queue_name, queue_list.data AS queue_list_data, queue_list.`status` AS queue_list_status, queue_list.updated_time AS queue_list_updated_time, queue_list.created_time AS queue_list_created_time

FROM queue_list

WHERE queue_list.`status` = %s ORDER BY queue_list.id ASC

LIMIT %s

2021-05-19 02:39:45,136 INFO sqlalchemy.engine.base.Engine (-1, 1)

2021-05-19 02:39:45,139 INFO sqlalchemy.engine.base.Engine SELECT oauth_member_bind.id AS oauth_member_bind_id, oauth_member_bind.member_id AS oauth_member_bind_member_id, oauth_member_bind.client_type AS oauth_member_bind_client_type, oauth_member_bind.type AS oauth_member_bind_type, oauth_member_bind.openid AS oauth_member_bind_openid, oauth_member_bind.unionid AS oauth_member_bind_unionid, oauth_member_bind.extra AS oauth_member_bind_extra, oauth_member_bind.updated_time AS oauth_member_bind_updated_time, oauth_member_bind.created_time AS oauth_member_bind_created_time

FROM oauth_member_bind

WHERE oauth_member_bind.member_id = %s

LIMIT %s

2021-05-19 02:39:45,139 INFO sqlalchemy.engine.base.Engine (9, 1)

2021-05-19 02:39:45,142 INFO sqlalchemy.engine.base.Engine SELECT pay_order.id AS pay_order_id, pay_order.order_sn AS pay_order_order_sn, pay_order.member_id AS pay_order_member_id, pay_order.total_price AS pay_order_total_price, pay_order.yun_price AS pay_order_yun_price, pay_order.pay_price AS pay_order_pay_price, pay_order.pay_sn AS pay_order_pay_sn, pay_order.prepay_id AS pay_order_prepay_id, pay_order.note AS pay_order_note, pay_order.serve_order_time AS pay_order_serve_order_time, pay_order.`status` AS pay_order_status, pay_order.serve_status AS pay_order_serve_status, pay_order.serve_address_id AS pay_order_serve_address_id, pay_order.serve_express_info AS pay_order_serve_express_info, pay_order.comment_status AS pay_order_comment_status, pay_order.pay_time AS pay_order_pay_time, pay_order.updated_time AS pay_order_updated_time, pay_order.created_time AS pay_order_created_time

FROM pay_order

WHERE pay_order.id = %s

LIMIT %s

2021-05-19 02:39:45,142 INFO sqlalchemy.engine.base.Engine (1, 1)

2021-05-19 02:39:45,146 INFO sqlalchemy.engine.base.Engine SELECT pay_order_item.id AS pay_order_item_id, pay_order_item.pay_order_id AS pay_order_item_pay_order_id, pay_order_item.member_id AS pay_order_item_member_id, pay_order_item.quantity AS pay_order_item_quantity, pay_order_item.price AS pay_order_item_price, pay_order_item.serve_id AS pay_order_item_serve_id, pay_order_item.note AS pay_order_item_note, pay_order_item.serve_order_time AS pay_order_item_serve_order_time, pay_order_item.`status` AS pay_order_item_status, pay_order_item.updated_time AS pay_order_item_updated_time, pay_order_item.created_time AS pay_order_item_created_time

FROM pay_order_item

WHERE pay_order_item.pay_order_id = %s

2021-05-19 02:39:45,146 INFO sqlalchemy.engine.base.Engine (1,)

2021-05-19 02:39:45,149 INFO sqlalchemy.engine.base.Engine SELECT serve.id AS serve_id, serve.cat_id AS serve_cat_id, serve.name AS serve_name, serve.price AS serve_price, serve.main_image AS serve_main_image, serve.summary AS serve_summary, serve.stock AS serve_stock, serve.tags AS serve_tags, serve.`status` AS serve_status, serve.month_count AS serve_month_count, serve.total_count AS serve_total_count, serve.view_count AS serve_view_count, serve.comment_count AS serve_comment_count, serve.updated_time AS serve_updated_time, serve.created_time AS serve_created_time

FROM serve

WHERE serve.id = %s

LIMIT %s

2021-05-19 02:39:45,149 INFO sqlalchemy.engine.base.Engine (21, 1)

2021-05-19 02:39:45,154 INFO sqlalchemy.engine.base.Engine SELECT serve_sale_change_log.id AS serve_sale_change_log_id, serve_sale_change_log.serve_id AS serve_sale_change_log_serve_id, serve_sale_change_log.quantity AS serve_sale_change_log_quantity, serve_sale_change_log.price AS serve_sale_change_log_price, serve_sale_change_log.member_id AS serve_sale_change_log_member_id, serve_sale_change_log.created_time AS serve_sale_change_log_created_time, sum(serve_sale_change_log.quantity) AS total

FROM serve_sale_change_log

WHERE serve_sale_change_log.serve_id = %s AND serve_sale_change_log.created_time >= %s AND serve_sale_change_log.created_time <= %s

LIMIT %s

2021-05-19 02:39:45,154 INFO sqlalchemy.engine.base.Engine (21, '2021-05-01 00:00:00', '2021-05-31 23:59:59', 1)

Traceback (most recent call last):

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/sqlalchemy/engine/base.py", line 1277, in _execute_context

cursor, statement, parameters, context

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/sqlalchemy/engine/default.py", line 609, in do_execute

cursor.execute(statement, parameters)

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/MySQLdb/cursors.py", line 206, in execute

res = self._query(query)

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/MySQLdb/cursors.py", line 319, in _query

db.query(q)

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/MySQLdb/connections.py", line 259, in query

_mysql.connection.query(self, query)

MySQLdb._exceptions.OperationalError: (1140, "In aggregated query without GROUP BY, expression #1 of SELECT list contains nonaggregated column 'serve_db.serve_sale_change_log.id'; this is incompatible with sql_mode=only_full_group_by")

The above exception was the direct cause of the following exception:

Traceback (most recent call last):

File "/media/psf/Home/PycharmProjects/cyh_order/jobs/launcher.py", line 56, in run

target.run(ret_params)

File "/media/psf/Home/PycharmProjects/cyh_order/jobs/tasks/queue/index.py", line 32, in run

self.handlePay(item)

File "/media/psf/Home/PycharmProjects/cyh_order/jobs/tasks/queue/index.py", line 69, in handlePay

ServeSaleChangeLog.created_time <= date_to).first()

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/sqlalchemy/orm/query.py", line 3429, in first

ret = list(self[0:1])

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/sqlalchemy/orm/query.py", line 3203, in __getitem__

return list(res)

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/sqlalchemy/orm/query.py", line 3535, in __iter__

return self._execute_and_instances(context)

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/sqlalchemy/orm/query.py", line 3560, in _execute_and_instances

result = conn.execute(querycontext.statement, self._params)

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/sqlalchemy/engine/base.py", line 1011, in execute

return meth(self, multiparams, params)

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/sqlalchemy/sql/elements.py", line 298, in _execute_on_connection

return connection._execute_clauseelement(self, multiparams, params)

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/sqlalchemy/engine/base.py", line 1130, in _execute_clauseelement

distilled_params,

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/sqlalchemy/engine/base.py", line 1317, in _execute_context

e, statement, parameters, cursor, context

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/sqlalchemy/engine/base.py", line 1511, in _handle_dbapi_exception

sqlalchemy_exception, with_traceback=exc_info[2], from_=e

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/sqlalchemy/util/compat.py", line 182, in raise_

raise exception

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/sqlalchemy/engine/base.py", line 1277, in _execute_context

cursor, statement, parameters, context

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/sqlalchemy/engine/default.py", line 609, in do_execute

cursor.execute(statement, parameters)

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/MySQLdb/cursors.py", line 206, in execute

res = self._query(query)

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/MySQLdb/cursors.py", line 319, in _query

db.query(q)

File "/home/parallels/cyhtry_env/lib64/python3.6/site-packages/MySQLdb/connections.py", line 259, in query

_mysql.connection.query(self, query)

sqlalchemy.exc.OperationalError: (MySQLdb._exceptions.OperationalError) (1140, "In aggregated query without GROUP BY, expression #1 of SELECT list contains nonaggregated column 'serve_db.serve_sale_change_log.id'; this is incompatible with sql_mode=only_full_group_by")

[SQL: SELECT serve_sale_change_log.id AS serve_sale_change_log_id, serve_sale_change_log.serve_id AS serve_sale_change_log_serve_id, serve_sale_change_log.quantity AS serve_sale_change_log_quantity, serve_sale_change_log.price AS serve_sale_change_log_price, serve_sale_change_log.member_id AS serve_sale_change_log_member_id, serve_sale_change_log.created_time AS serve_sale_change_log_created_time, sum(serve_sale_change_log.quantity) AS total

FROM serve_sale_change_log

WHERE serve_sale_change_log.serve_id = %s AND serve_sale_change_log.created_time >= %s AND serve_sale_change_log.created_time <= %s

LIMIT %s]

[parameters: (21, '2021-05-01 00:00:00', '2021-05-31 23:59:59', 1)]

(Background on this error at: http://sqlalche.me/e/13/e3q8)

2021-05-19 02:39:45,161 INFO sqlalchemy.engine.base.Engine ROLLBACK