【Looker × LINE】LINE 公式アカウントを使ったデータ活用を試してみた

def action_list(request):
    """Return action hub list endpoint data for action"""
    auth = authenticate(request)
    if auth.status_code != 200:
        return auth

    response = {
        'label': 'LINE Official',
        'integrations': [{
            'name': 'LINE公式',
            'label': 'LINE公式',
            'supported_action_types': ['cell','query'],
            "required_fields": [{"tag":"cell_id"}],
            "icon_data_uri": icon_data_uri,
            'form_url': BASE_DOMAIN + 'form',
            'url': BASE_DOMAIN + 'execute',
            'supported_formats': ['json'],
            'supported_formattings': ['formatted'],
            'supported_visualization_formattings': ['noapply'],
            'params': []
        }]
    }

    print('returning integrations json')
    return Response(json.dumps(response), status=200, mimetype='application/json')

def action_form(request):
    """Return form endpoint data for action"""
    auth = authenticate(request)
    if auth.status_code != 200:
        return auth

    response = [
        {
        'name': 'message',
        'label': 'メッセージ',
        'description': '送信メッセージを入力してください',
        'type': 'textarea',
        'required': True
    }]

    print('returning form json: {}'.format(json.dumps(response)))
    return Response(json.dumps(response), status=200, mimetype='application/json')

def action_execute(request):
    """Generate a response from Generative AI Studio from a Looker action"""
    auth = authenticate(request)
    if auth.status_code != 200:
        return auth
    request_json = request.get_json()
    attachment = request_json['attachment']
    action_params = request_json['data']
    form_params = request_json['form_params']
    print(action_params)
    print(form_params)

    configuration = linebot.v3.messaging.Configuration(
        host = "https://api.line.me"
    )
    # access_tokenを設定
    configuration = linebot.v3.messaging.Configuration(
        access_token=os.environ.get("CHANNEL_ACCESS_TOKEN")
    )

    message = '{\"to\":\"\",\"messages\":[{\"type\":\"text\",\"text\":\"\"}]}'

    message_dict = json.loads(message)

    #query処理
    try:
        all_data = sanitize_and_load_json_str(attachment['data'])
        print(f"all_data {all_data}")

    except Exception as e:
        body = 'Warn: Attachment Data loading Error: ' + str(e)
        print(body)
    try:
        for key in all_data:
            if not key[os.environ.get("LINE_ID_COLUMN")] is None:
                print(os.environ.get("LINE_ID_COLUMN"))

                message_dict['to'] = key[os.environ.get("LINE_ID_COLUMN")]
                message_dict['messages'][0]['text'] = form_params['message']
                with linebot.v3.messaging.ApiClient(configuration) as api_client:
                    api_instance = linebot.v3.messaging.MessagingApi(api_client)
                    push_message_request = linebot.v3.messaging.PushMessageRequest.from_dict(message_dict)
                    api_response = api_instance.push_message(push_message_request)
                    print("The response of MessagingApi->push_message:\n")
                    pprint(api_response)
        return Response(status=200, mimetype='application/json')
    except Exception as e:
        body = 'Warn: Attachment Data loop Error: ' + str(e)
        print(body)
        
    #cell処理
    message_dict['to'] = action_params['value']
    message_dict['messages'][0]['text'] = form_params['message']

    with linebot.v3.messaging.ApiClient(configuration) as api_client:
        api_instance = linebot.v3.messaging.MessagingApi(api_client)
        push_message_request = linebot.v3.messaging.PushMessageRequest.from_dict(message_dict)

        try:
            api_response = api_instance.push_message(push_message_request)
            print("The response of MessagingApi->push_message:\n")
            pprint(api_response)
        except Exception as e:
            print("Exception when calling MessagingApi->push_message: %s\n" % e)

    return Response(status=200, mimetype='application/json')

    #Query処理
    try:
        all_data = sanitize_and_load_json_str(attachment['data'])
        print(f"all_data {all_data}")

    except Exception as e:
        body = 'Warn: Attachment Data loading Error: ' + str(e)
        print(body)
    try:
        for key in all_data:
            if not key[os.environ.get("LINE_ID_COLUMN")] is None:
                print(os.environ.get("LINE_ID_COLUMN"))

                message_dict['to'] = key[os.environ.get("LINE_ID_COLUMN")]
                message_dict['messages'][0]['text'] = form_params['message']
                with linebot.v3.messaging.ApiClient(configuration) as api_client:
                    api_instance = linebot.v3.messaging.MessagingApi(api_client)
                    push_message_request = linebot.v3.messaging.PushMessageRequest.from_dict(message_dict)
                    api_response = api_instance.push_message(push_message_request)
                    print("The response of MessagingApi->push_message:\n")
                    pprint(api_response)
        return Response(status=200, mimetype='application/json')
    except Exception as e:
        body = 'Warn: Attachment Data loop Error: ' + str(e)
        print(body)
        
   

    #Cell処理
    message_dict['to'] = action_params['value']
    message_dict['messages'][0]['text'] = form_params['message']

    with linebot.v3.messaging.ApiClient(configuration) as api_client:
        api_instance = linebot.v3.messaging.MessagingApi(api_client)
        push_message_request = linebot.v3.messaging.PushMessageRequest.from_dict(message_dict)

        try:
            api_response = api_instance.push_message(push_message_request)
            print("The response of MessagingApi->push_message:\n")
            pprint(api_response)
        except Exception as e:
            print("Exception when calling MessagingApi->push_message: %s\n" % e)

    return Response(status=200, mimetype='application/json')