Line Messaging

line 是国外一个很火的实时通信软件，类似与WX，由于公司业务需求，需要基于line开发一个聊天平台，下面主要介绍关于line messaging api 的使用。

官方api：https://developers.line.biz/en/docs/messaging-api/overview/

起步

创建开发人员账号和创建channel

官方教程：https://developers.line.biz/en/docs/line-developers-console/overview/

python开发人员使用

1. 安装 module

   pip install line-bot-sdk
   

2. 要求：python2 >= 2.7 或 python3 >=3.4

3. 示例

   from flask import Flask, request, abort
   
   from linebot import (
       LineBotApi, WebhookHandler
   )
   from linebot.exceptions import (
       InvalidSignatureError
   )
   from linebot.models import (
       MessageEvent, TextMessage, TextSendMessage,
   )
   
   app = Flask(__name__)
   
   line_bot_api = LineBotApi('YOUR_CHANNEL_ACCESS_TOKEN') # channel的token，创建channel之后有
   handler = WebhookHandler('YOUR_CHANNEL_SECRET')  #  channel的secret，创建channel之后有
   
   
   @app.route("/callback", methods=['POST'])
   def callback():  # 用于确认通信
       # get X-Line-Signature header value
       signature = request.headers['X-Line-Signature']
   
       # get request body as text
       body = request.get_data(as_text=True)
       app.logger.info("Request body: " + body)
   
       # handle webhook body
       try:
           handler.handle(body, signature)
       except InvalidSignatureError:
           print("Invalid signature. Please check your channel access token/channel secret.")
           abort(400)
   
       return 'OK'
   
   
   @handler.add(MessageEvent, message=TextMessage)  # 处理消息事件，text类型的信息
   def handle_message(event):
       line_bot_api.reply_message(  # 回复消息
           event.reply_token,
           TextSendMessage(text=event.message.text)
       )
   
   
   if __name__ == "__main__":
       app.run()
   

Python Api

githup: https://github.com/line/line-bot-sdk-python

创建实例

line_bot_api = linebot.LineBotApi('YOUR_CHANNEL_ACCESS_TOKEN')

line_bot_api.reply_message(reply_token, TextSendMessage(text='Hello World!'))

line_bot_api.push_message(to, TextSendMessage(text='Hello World!'))

line_bot_api.multicast(['to1', 'to2'], TextSendMessage(text='Hello World!'))

line_bot_api.broadcast(TextSendMessage(text='Hello World!'))

profile = line_bot_api.get_profile(user_id) # 通过用户id，获取用户信息

print(profile.display_name)
print(profile.user_id)
print(profile.picture_url)
print(profile.status_message)

message_content = line_bot_api.get_message_content(message_id)
basedir = os.path.abspath(os.path.dirname(__file__))
file_path = basedir + "../.."
with open(file_path, 'wb') as fd:
    for chunk in message_content.iter_content():
        fd.write(chunk)

bot_info = line_bot_api.get_bot_info()

print(bot_info.display_name)
print(bot_info.user_id)
print(bot_info.basic_id)
print(bot_info.premium_id)
print(bot_info.picture_url)
print(bot_info.chat_mode)
print(bot_info.mark_as_read_mode)

try:
    line_bot_api.push_message('to', TextSendMessage(text='Hello World!'))
except linebot.exceptions.LineBotApiError as e:
    print(e.status_code)
    print(e.request_id)
    print(e.error.message)
    print(e.error.details)

{
  "destination": "xxxxxxxxxx",
  "events": [
    {
      "replyToken": "0f3779fba3b349968c5d07db31eab56f",
      "type": "message",
      "mode": "active",
      "timestamp": 1462629479859,
      "source": {
        "type": "user",
        "userId": "U4af4980629..."
      },
      "message": {
        "id": "325708",
        "type": "text",
        "text": "Hello, world"
      }
    },
    {
      "replyToken": "8cf9239d56244f4197887e939187e19e",
      "type": "follow",
      "mode": "active",
      "timestamp": 1462629479859,
      "source": {
        "type": "user",
        "userId": "U4af4980629..."
      }
    }
  ]
}