修改逻辑
This commit is contained in:
parent
0d5cf62944
commit
148b46f322
@ -3,7 +3,9 @@ ADD app.py requirements.txt /app/
|
|||||||
ENV SLACK_SIGNING_SECRET=***
|
ENV SLACK_SIGNING_SECRET=***
|
||||||
ENV SLACK_BOT_TOKEN=xoxb-***
|
ENV SLACK_BOT_TOKEN=xoxb-***
|
||||||
ENV DINGTALK_WEBHOOK='https://oapi.dingtalk.com/robot/send?access_token=这里填写自己钉钉群自定义机器人的token'
|
ENV DINGTALK_WEBHOOK='https://oapi.dingtalk.com/robot/send?access_token=这里填写自己钉钉群自定义机器人的token'
|
||||||
|
ENV PORT=3000
|
||||||
WORKDIR /app
|
WORKDIR /app
|
||||||
RUN pip install -r requirements.txt
|
RUN pip install -r requirements.txt
|
||||||
RUN chmod +x app.py
|
RUN chmod +x app.py
|
||||||
|
EXPOSE 3000
|
||||||
ENTRYPOINT [ "python", "app.py" ]
|
ENTRYPOINT [ "python", "app.py" ]
|
32
app.py
32
app.py
@ -1,54 +1,44 @@
|
|||||||
from dingtalkchatbot.chatbot import DingtalkChatbot
|
from dingtalkchatbot.chatbot import DingtalkChatbot
|
||||||
from slack_bolt.async_app import AsyncApp
|
from slack_bolt import App
|
||||||
from slack_bolt.authorization import AuthorizeResult
|
|
||||||
from slack_sdk.web.async_client import AsyncWebClient
|
|
||||||
import os
|
import os
|
||||||
import logging
|
import logging
|
||||||
logging.basicConfig(level=logging.DEBUG)
|
logging.basicConfig(level=logging.DEBUG)
|
||||||
|
|
||||||
# Import the async app instead of the regular one
|
|
||||||
|
|
||||||
|
|
||||||
async def authorize(enterprise_id, team_id, user_id, client: AsyncWebClient, logger):
|
|
||||||
logger.info(f"{enterprise_id},{team_id},{user_id}")
|
|
||||||
# You can implement your own logic here
|
|
||||||
token = os.environ["SLACK_BOT_TOKEN"]
|
|
||||||
return AuthorizeResult.from_auth_test_response(
|
|
||||||
auth_test_response=await client.auth_test(token=token),
|
|
||||||
bot_token=token,
|
|
||||||
)
|
|
||||||
|
|
||||||
# WebHook地址
|
# WebHook地址
|
||||||
dingtalk_webhook = os.environ["DINGTALK_WEBHOOK"]
|
dingtalk_webhook = os.environ["DINGTALK_WEBHOOK"]
|
||||||
|
|
||||||
dingtalkbot = DingtalkChatbot(dingtalk_webhook)
|
dingtalkbot = DingtalkChatbot(dingtalk_webhook)
|
||||||
app = AsyncApp(
|
app = App(
|
||||||
signing_secret=os.environ["SLACK_SIGNING_SECRET"], authorize=authorize)
|
token=os.environ.get("SLACK_BOT_TOKEN"),
|
||||||
|
signing_secret=os.environ.get("SLACK_SIGNING_SECRET")
|
||||||
|
)
|
||||||
|
|
||||||
|
|
||||||
@app.event("app_mention")
|
@app.event("app_mention")
|
||||||
async def event_test(body, say, logger):
|
def event_test(body, say, logger):
|
||||||
logger.info(body)
|
logger.info(body)
|
||||||
await say("What's up?")
|
await say("What's up?")
|
||||||
|
|
||||||
|
|
||||||
@app.command("/hello-bolt-python")
|
@app.command("/hello-bolt-python")
|
||||||
async def command(ack, body, respond):
|
def command(ack, body, respond):
|
||||||
await ack()
|
await ack()
|
||||||
await respond(f"Hi <@{body['user_id']}>!")
|
await respond(f"Hi <@{body['user_id']}>!")
|
||||||
|
|
||||||
|
|
||||||
@app.message("Heads Up!*")
|
@app.message("Heads Up!*")
|
||||||
async def redirect(body, logger):
|
def redirect(body, logger):
|
||||||
logger.info(body)
|
logger.info(body)
|
||||||
|
dingtalkbot.send_text(body)
|
||||||
|
|
||||||
|
|
||||||
@app.message("")
|
@app.message("")
|
||||||
async def logall(body, logger):
|
def logall(body, logger):
|
||||||
logger.debug(body)
|
logger.debug(body)
|
||||||
dingtalkbot.send_text(body)
|
dingtalkbot.send_text(body)
|
||||||
|
|
||||||
|
|
||||||
# 启动slack监听
|
# 启动slack监听
|
||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
app.start(3000)
|
app.start(os.environ.get("PORT", 3000))
|
||||||
|
@ -2,3 +2,5 @@ export SLACK_SIGNING_SECRET=***
|
|||||||
export SLACK_BOT_TOKEN=xoxb-***
|
export SLACK_BOT_TOKEN=xoxb-***
|
||||||
|
|
||||||
export DINGTALK_WEBHOOK='https://oapi.dingtalk.com/robot/send?access_token=这里填写自己钉钉群自定义机器人的token'
|
export DINGTALK_WEBHOOK='https://oapi.dingtalk.com/robot/send?access_token=这里填写自己钉钉群自定义机器人的token'
|
||||||
|
|
||||||
|
export PORT=3000
|
||||||
|
Loading…
x
Reference in New Issue
Block a user